|
50
|
1 package christie.topology.manager;
|
|
|
2
|
|
121
|
3 import christie.codegear.CodeGear;
|
|
50
|
4 import christie.codegear.CodeGearManager;
|
|
|
5 import christie.codegear.StartCodeGear;
|
|
121
|
6 import christie.topology.node.Start;
|
|
50
|
7
|
|
|
8 public class StartTopologyManager extends StartCodeGear{
|
|
|
9
|
|
111
|
10 public StartTopologyManager(String[] args){
|
|
121
|
11 this(createCGM(new TopologyManagerConfig(args).localPort),
|
|
|
12 new TopologyManagerConfig(args));
|
|
|
13 }
|
|
|
14
|
|
|
15 public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){
|
|
|
16 this(createCGM(topologyManagerConfig.localPort), topologyManagerConfig);
|
|
111
|
17 }
|
|
96
|
18
|
|
60
|
19 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){
|
|
50
|
20 super(cgm);
|
|
121
|
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
|
|
96
|
37 }
|
|
|
38
|
|
|
39
|
|
|
40
|
|
111
|
41 public static void main(String[] args) {
|
|
|
42 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args);
|
|
|
43 new StartTopologyManager(topologyManagerConfig);
|
|
|
44 }
|
|
|
45
|
|
121
|
46
|
|
50
|
47 }
|
|
96
|
48
|
