Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/StartTopologyManager.java @ 121:8949d0ecf1f6

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
refactor Topology
author akahori
date Tue, 11 Dec 2018 15:46:09 +0900
parents 671246274719
children c7300be0fff6
comparison
equal deleted inserted replaced
120:7ca232bc1009 121:8949d0ecf1f6
1 package christie.topology.manager; 1 package christie.topology.manager;
2 2
3 import christie.codegear.CodeGear;
3 import christie.codegear.CodeGearManager; 4 import christie.codegear.CodeGearManager;
4 import christie.codegear.StartCodeGear; 5 import christie.codegear.StartCodeGear;
6 import christie.topology.node.Start;
5 7
6 public class StartTopologyManager extends StartCodeGear{ 8 public class StartTopologyManager extends StartCodeGear{
7 9
8 public StartTopologyManager(String[] args){ 10 public StartTopologyManager(String[] args){
9 super(createCGM(new TopologyManagerConfig(args).localPort)); 11 this(createCGM(new TopologyManagerConfig(args).localPort),
10 getLocalDGM().put("topologyManagerConfig", new TopologyManagerConfig(args)); 12 new TopologyManagerConfig(args));
13 }
14
15 public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){
16 this(createCGM(topologyManagerConfig.localPort), topologyManagerConfig);
11 } 17 }
12 18
13 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){ 19 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){
14 super(cgm); 20 super(cgm);
15 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); 21 cgm.setup(new TopologyManager());
22 cgm.getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
23 }
24
25 public StartTopologyManager(TopologyManagerConfig conf, CodeGear startCG) {
26 this(createCGM(conf.localPort), conf, startCG);
27
28 }
29
30 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig conf, CodeGear startCG) {
31 super(cgm);
32 cgm.setup(new TopologyManager());
33 cgm.setup(new Start());
34 cgm.getLocalDGM().put("startCG", startCG);
35 cgm.getLocalDGM().put("topologyNodeConfig", conf);
36
16 } 37 }
17 38
18 39
19 public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){
20 super(createCGM(topologyManagerConfig.localPort));
21 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
22 }
23 40
24 public static void main(String[] args) { 41 public static void main(String[] args) {
25 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args); 42 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args);
26 new StartTopologyManager(topologyManagerConfig); 43 new StartTopologyManager(topologyManagerConfig);
27 } 44 }
28 45
29 @Override 46
30 protected void run(CodeGearManager cgm){
31 cgm.setup(new TopologyManager());
32 }
33 } 47 }
34 48