package christie.topology.manager;

import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.topology.Message;


public class TopologyFinish extends CodeGear {
    @Take
    Message FINISHMESSAGE;

    @Peek
    TopologyManagerConfig topologyManagerConfig;

    @Take
    Long startTime;

    @Override
    protected void run(CodeGearManager cgm) {
        if (topologyManagerConfig.showTime) {
            System.out.println("TopologymanagerTime = " + (System.currentTimeMillis() - startTime));
        }


       for(String dgm : cgm.getDGMList().keySet()){
            getDGM(dgm).put("_CLOSEMESSEAGE", new Message());
            getDGM(dgm).shutdown();
        }

        getLocalDGM().finish();

    }

}