package alice.topology.node;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.DataSegment;
import alice.datasegment.Receiver;

public class ReceiveCloseMessage extends CodeSegment {

    private Receiver info = ids.create(CommandType.TAKE);

    public ReceiveCloseMessage() {
        info.setKey("_CLOSEMESSEAGE");
    }

    @Override
    public void run() {
        String managerKey = info.asString();
        if (DataSegment.contains(managerKey)) {
            DataSegment.get(managerKey).setSendError(false);
            DataSegment.get(managerKey).shutdown();
        } else {

        }


        new ReceiveCloseMessage();
    }

}