|
50
|
1 package christie.topology.manager;
|
|
|
2
|
|
|
3 import christie.codegear.CodeGearManager;
|
|
|
4 import christie.codegear.StartCodeGear;
|
|
|
5
|
|
|
6 public class StartTopologyManager extends StartCodeGear{
|
|
|
7
|
|
111
|
8 public StartTopologyManager(String[] args){
|
|
|
9 super(createCGM(new TopologyManagerConfig(args).localPort));
|
|
|
10 getLocalDGM().put("topologyManagerConfig", new TopologyManagerConfig(args));
|
|
|
11 }
|
|
96
|
12
|
|
60
|
13 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){
|
|
50
|
14 super(cgm);
|
|
111
|
15 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
|
|
96
|
16 }
|
|
|
17
|
|
|
18
|
|
|
19 public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){
|
|
|
20 super(createCGM(topologyManagerConfig.localPort));
|
|
|
21 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
|
|
|
22 }
|
|
|
23
|
|
111
|
24 public static void main(String[] args) {
|
|
|
25 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args);
|
|
|
26 new StartTopologyManager(topologyManagerConfig);
|
|
|
27 }
|
|
|
28
|
|
96
|
29 @Override
|
|
|
30 protected void run(CodeGearManager cgm){
|
|
60
|
31 cgm.setup(new TopologyManager());
|
|
50
|
32 }
|
|
|
33 }
|
|
96
|
34
|
