package christie.topology.node;


import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.datagear.DataGearManager;

import java.util.List;

public class PrepareToClose extends CodeGear {

    @Take
    String _CLOSEMESSEAGE;

    @Take
    List<String> _CLIST;

    @Peek
    TopologyNodeConfig topologyNodeConfig;


    public PrepareToClose() {

    }

    @Override
    protected void run(CodeGearManager cgm) {

        for(String dgmName: _CLIST){
            getDGM(dgmName).shutdown();
            //_CLIST.remove(dgmName);
        }

        getLocalDGM().finish();

        /*if (_CLIST.contains(_CLOSEMESSEAGE)) {
            _CLIST.remove(_CLOSEMESSEAGE);

            getDGM(_CLOSEMESSEAGE).setSendError(false);
            getDGM(_CLOSEMESSEAGE).close();

            getDGM(_CLOSEMESSEAGE).put("_CLOSEREADY", _CLOSEMESSEAGE);
            getLocalDGM().put("_CLOSEREADY", _CLOSEMESSEAGE);

            cgm.setup(new CloseRemoteDataGear());
        }
        cgm.setup(new PrepareToClose());
        getLocalDGM().put("_CLIST", _CLIST);*/

    }

}