diff src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java @ 79:0a724c973fc9

fix conffile
author akahori
date Wed, 05 Sep 2018 10:47:04 +0900
parents 32f6f9de97c1
children 1e66fd626aff
line wrap: on
line diff
--- a/src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java	Wed Sep 05 10:35:46 2018 +0900
+++ b/src/main/java/christie/test/topology/localTestTopology/StartLocalTestTopology.java	Wed Sep 05 10:47:04 2018 +0900
@@ -22,15 +22,17 @@
         configs.add(new LocalTestTopologyConfig(args, 10001, "node0"));
         configs.add(new LocalTestTopologyConfig(args, 10002, "node1"));
         configs.add(new LocalTestTopologyConfig(args, 10003, "node2"));
-
-        TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(new String[]{"--confFile", "scripts/ring.dot", "--showTime"});
-        CodeGearManager topologyManagerCGM = createCGM(10000);
+        String[] managerArg = {"--localPort", String.valueOf(10000), "--confFile", "scripts/ring.dot", "--showTime"};
+        TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
+        CodeGearManager topologyManagerCGM = createCGM(topologyManagerConfig.localPort);
         new StartTopologyManager(topologyManagerCGM, topologyManagerConfig);
 
         for (LocalTestTopologyConfig conf: configs ) {
-            CodeGearManager nodeCGM = createCGM(conf.connectPort);
-            String[] csarg = {"--host","localhost","--localKey",conf.key };
-            TopologyNodeConfig cs  = new TopologyNodeConfig(csarg);
+            CodeGearManager nodeCGM = createCGM(conf.localPort);
+            String[] nodeArg = {"--localKey",conf.key,
+                                "--managerPort", String.valueOf(topologyManagerConfig.localPort),
+                                "--managerHost", "localhost"};
+            TopologyNodeConfig cs  = new TopologyNodeConfig(nodeArg);
 
             new StartTopologyNode(nodeCGM, cs, new LTRemoteIncrement(conf));
         }