changeset 128:2886363f5e12

update put
author akahori
date Tue, 25 Dec 2018 15:13:59 +0900
parents 42f195de3152
children 2e2d761ea806
files src/main/java/christie/codegear/CodeGear.java src/test/java/christie/localTestTopology/localTestTopology.java
diffstat 2 files changed, 45 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/christie/codegear/CodeGear.java	Tue Dec 18 15:14:45 2018 +0900
+++ b/src/main/java/christie/codegear/CodeGear.java	Tue Dec 25 15:13:59 2018 +0900
@@ -66,12 +66,15 @@
         return cgm.getDGM(dgmName);
     }
 
-    public void put(String dgmName, String key, Object data){
+    public CodeGear put(String dgmName, String key, Object data){
         getDGM(dgmName).put(key, data);
+        return this;
     }
 
-    public void put(String key, Object value){
+    public CodeGear put(String key, Object value){
+
         localDGM.put(key, value);
+        return this;
     }
 
     public Boolean containsDGM(String dgmName){ return cgm.containsDGM(dgmName);}
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/test/java/christie/localTestTopology/localTestTopology.java	Tue Dec 25 15:13:59 2018 +0900
@@ -0,0 +1,40 @@
+package christie.localTestTopology;
+
+import christie.test.topology.localTestTopology.LTRemoteIncrement;
+import christie.topology.manager.StartTopologyManager;
+import christie.topology.manager.TopologyManagerConfig;
+import christie.topology.node.StartTopologyNode;
+import christie.topology.node.TopologyNodeConfig;
+
+public class localTestTopology {
+
+
+    public static void main(String[] args) {
+        /* Local Test */
+        int managerPort = 10000;
+        int nodeNum = 3;
+        String[] managerArg = {"--localPort", String.valueOf(managerPort), "--confFile", "scripts/ring.dot"};
+        TopologyManagerConfig topologyManagerConfig = new TopologyManagerConfig(managerArg);
+        new StartTopologyManager(topologyManagerConfig);
+
+
+        for (int i = 1; i<=nodeNum; i++) {
+
+            String[] nodeArg = {"--managerPort", String.valueOf(managerPort),
+                    "--managerHost", "localhost",
+                    "--localPort", String.valueOf(managerPort + i)};
+            /*try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }*/
+            TopologyNodeConfig topologyNodeConfig = new TopologyNodeConfig(nodeArg);
+            StartTopologyNode startTopologyNode = new StartTopologyNode(topologyNodeConfig, new LTRemoteIncrement());
+            startTopologyNode.getLocalDGM().put("num", 0);
+
+        }
+
+
+    }
+
+}