view src/main/java/christie/topology/manager/StartTopologyManager.java @ 168:c7300be0fff6

fix incomingHosts end message
author akahori
date Tue, 22 Jan 2019 16:00:29 +0900
parents 8949d0ecf1f6
children
line wrap: on
line source

package christie.topology.manager;

import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.codegear.StartCodeGear;
import christie.topology.node.Start;

public class StartTopologyManager extends StartCodeGear{

    public StartTopologyManager(String[] args){
        this(createCGM(new TopologyManagerConfig(args).localPort),
                new TopologyManagerConfig(args));
    }

    public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){
        this(createCGM(topologyManagerConfig.localPort), topologyManagerConfig);
    }

    public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){
        super(cgm);
        cgm.setup(new TopologyManager());
        cgm.getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
    }

    public StartTopologyManager(TopologyManagerConfig conf, CodeGear startCG) {
        this(createCGM(conf.localPort), conf, startCG);

    }

    public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig conf, CodeGear startCG) {
        super(cgm);
        cgm.setup(new TopologyManager());
        cgm.setup(new Start());
        cgm.getLocalDGM().put("startCG", startCG);
        cgm.getLocalDGM().put("topologyNodeConfig", conf);

    }


    public static void main(String[] args) {
        TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args);
        new StartTopologyManager(topologyManagerConfig);
    }


}