Mercurial > hg > Database > Christie
view src/main/java/christie/topology/manager/StartTopologyManager.java @ 121:8949d0ecf1f6
refactor Topology
author | akahori |
---|---|
date | Tue, 11 Dec 2018 15:46:09 +0900 |
parents | 671246274719 |
children | c7300be0fff6 |
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); } }