# HG changeset patch # User akahori # Date 1537150826 -32400 # Node ID bf6ab64325f93246c321a4f179ae344bd87674e0 # Parent 5cd99bac9abd583e404da82a6fb37ee16318caa6 add Constoractor diff -r 5cd99bac9abd -r bf6ab64325f9 src/main/java/christie/topology/manager/StartTopologyManager.java --- a/src/main/java/christie/topology/manager/StartTopologyManager.java Sat Sep 15 19:00:49 2018 +0900 +++ b/src/main/java/christie/topology/manager/StartTopologyManager.java Mon Sep 17 11:20:26 2018 +0900 @@ -5,9 +5,22 @@ public class StartTopologyManager extends StartCodeGear{ + public StartTopologyManager(CodeGearManager cgm, TopologyManagerConfig topologyManagerConfig){ super(cgm); cgm.getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); + } + + + public StartTopologyManager(TopologyManagerConfig topologyManagerConfig){ + super(createCGM(topologyManagerConfig.localPort)); + getLocalDGM().put("topologyManagerConfig", topologyManagerConfig); + } + + @Override + protected void run(CodeGearManager cgm){ cgm.setup(new TopologyManager()); + } } + diff -r 5cd99bac9abd -r bf6ab64325f9 src/main/java/christie/topology/node/StartTopologyNode.java --- a/src/main/java/christie/topology/node/StartTopologyNode.java Sat Sep 15 19:00:49 2018 +0900 +++ b/src/main/java/christie/topology/node/StartTopologyNode.java Mon Sep 17 11:20:26 2018 +0900 @@ -14,6 +14,13 @@ } + public StartTopologyNode(TopologyNodeConfig conf, CodeGear startCG) { + super(createCGM(conf.localPort)); + getLocalDGM().put("startCG", startCG); + getLocalDGM().put("topologyNodeConfig", conf); + + } + public static void main(String[] args) { TopologyNodeConfig conf = new TopologyNodeConfig(args); //new TopologyNode(conf, null); @@ -21,6 +28,8 @@ @Override protected void run(CodeGearManager cgm) { + cgm.setup(new TopologyNode()); + } }