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());
-    }
+
 }