view src/main/java/alice/topology/node/Start.java @ 518:fc313323c53b dispose

add reconnect event
author sugi
date Thu, 22 Jan 2015 16:01:32 +0900
parents 3fff2edc8d33
children 145c425db88d
line wrap: on
line source

package alice.topology.node;

import org.apache.log4j.Logger;

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

public class Start extends CodeSegment {

    public Receiver done = ids.create(CommandType.PEEK);
    public Receiver reconnect = ids.create(CommandType.PEEK);
    public Receiver config = ids.create(CommandType.PEEK);
    private Logger logger = Logger.getLogger(Start.class);
    private CodeSegment startCS;


    public Start(CodeSegment startCS) {
        this.startCS = startCS;
    }

    @Override
    public void run() {
        logger.info("Configuration finished.");
        boolean reconncet = this.reconnect.asClass(boolean.class);
        if (reconncet) {
            TopologyNodeConfig tnconfig = this.config.asClass(TopologyNodeConfig.class);
            tnconfig.executeEvent();
        }

        if (startCS == null)
            return;
        startCS.execute();

    }

}