--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main/java/christie/test/ring/ConnectManager.java	Sun Feb 18 23:44:15 2018 +0900
@@ -0,0 +1,30 @@
+package christie.test.ring;
+
+import christie.annotation.Peek;
+import christie.annotation.Take;
+import christie.codegear.CodeGear;
+import christie.codegear.CodeGearManager;
+
+public class ConnectManager extends CodeGear{
+    @Take
+    int nodePort;
+
+    @Peek
+    int max;
+
+    @Override
+    protected void run(CodeGearManager cgm) {
+        String nodeName = "node"+(nodePort-10000);
+        cgm.createRemoteDGM(nodeName, "localhost", nodePort);
+        getDGM(nodeName).put("hostname", nodeName);
+        getDGM(nodeName).put("address", "localhost");
+        if (nodePort-10000 < max-1){
+            getDGM(nodeName).put("port", nodePort+1);
+        } else {
+            getDGM(nodeName).put("port", 10000);
+            cgm.setup(new StartCount());
+            getLocalDGM().put("start_count", 1);
+        }
+        cgm.setup(new ConnectManager());
+    }
+}