Mercurial > hg > Database > Christie
diff 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 diff
--- a/src/main/java/christie/topology/manager/StartTopologyManager.java Tue Dec 11 15:43:45 2018 +0900 +++ b/src/main/java/christie/topology/manager/StartTopologyManager.java Tue Dec 11 15:46:09 2018 +0900 @@ -1,34 +1,48 @@ 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){ - super(createCGM(new TopologyManagerConfig(args).localPort)); - getLocalDGM().put("topologyManagerConfig", new TopologyManagerConfig(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); - getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); + 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 StartTopologyManager(TopologyManagerConfig topologyManagerConfig){ - super(createCGM(topologyManagerConfig.localPort)); - getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); - } public static void main(String[] args) { TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args); new StartTopologyManager(topologyManagerConfig); } - @Override - protected void run(CodeGearManager cgm){ - cgm.setup(new TopologyManager()); - } + }