Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/StartTopologyManager.java @ 111:671246274719

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix file dir
author akahori
date Tue, 20 Nov 2018 18:29:13 +0900
parents bf6ab64325f9
children 8949d0ecf1f6
comparison
equal deleted inserted replaced
110:eab161e557bd 111:671246274719
3 import christie.codegear.CodeGearManager; 3 import christie.codegear.CodeGearManager;
4 import christie.codegear.StartCodeGear; 4 import christie.codegear.StartCodeGear;
5 5
6 public class StartTopologyManager extends StartCodeGear{ 6 public class StartTopologyManager extends StartCodeGear{
7 7
8 public StartTopologyManager(String[] args){
9 super(createCGM(new TopologyManagerConfig(args).localPort));
10 getLocalDGM().put("topologyManagerConfig", new TopologyManagerConfig(args));
11 }
8 12
9 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){ 13 public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){
10 super(cgm); 14 super(cgm);
11 cgm.getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); 15 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
12 } 16 }
13 17
14 18
15 public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){ 19 public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){
16 super(createCGM(topologyManagerConfig.localPort)); 20 super(createCGM(topologyManagerConfig.localPort));
17 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); 21 getLocalDGM().put("topologyManagerConfig", topologyManagerConfig);
18 } 22 }
19 23
24 public static void main(String[] args) {
25 TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(args);
26 new StartTopologyManager(topologyManagerConfig);
27 }
28
20 @Override 29 @Override
21 protected void run(CodeGearManager cgm){ 30 protected void run(CodeGearManager cgm){
22 cgm.setup(new TopologyManager()); 31 cgm.setup(new TopologyManager());
23
24 } 32 }
25 } 33 }
26 34