--- a/src/main/java/christie/topology/manager/TopologyFinish.java	Fri Jan 25 19:24:29 2019 +0900
+++ b/src/main/java/christie/topology/manager/TopologyFinish.java	Fri Feb 01 12:28:23 2019 +0900
@@ -4,11 +4,12 @@
 import christie.annotation.Take;
 import christie.codegear.CodeGear;
 import christie.codegear.CodeGearManager;
+import christie.topology.Message;
 
 
 public class TopologyFinish extends CodeGear {
     @Take
-    String finish;
+    Message FINISHMESSAGE;
 
     @Peek
     TopologyManagerConfig topologyManagerConfig;
@@ -24,7 +25,7 @@
 
 
        for(String dgm : cgm.getDGMList().keySet()){
-            getDGM(dgm).put("_CLOSEMESSEAGE", "_CLOSEMESSEAGE");
+            getDGM(dgm).put("_CLOSEMESSEAGE", new Message());
             getDGM(dgm).shutdown();
         }