--- a/src/main/java/alice/topology/node/ReceiveCloseMessage.java	Wed Dec 10 20:31:09 2014 +0900
+++ b/src/main/java/alice/topology/node/ReceiveCloseMessage.java	Thu Dec 11 06:29:31 2014 +0900
@@ -2,29 +2,24 @@
 
 import alice.codesegment.CodeSegment;
 import alice.datasegment.CommandType;
-import alice.datasegment.DataSegment;
 import alice.datasegment.Receiver;
 
 public class ReceiveCloseMessage extends CodeSegment {
 
-    private Receiver info = ids.create(CommandType.TAKE);
+    private Receiver info;
 
-    public ReceiveCloseMessage() {
+    public ReceiveCloseMessage(CommandType type) {
+        info  = ids.create(type);
         info.setKey("_CLOSEMESSEAGE");
     }
 
     @Override
     public void run() {
-        String managerKey = info.asString();
-        if (DataSegment.contains(managerKey)) {
-            DataSegment.get(managerKey).setSendError(false);
-            DataSegment.get(managerKey).shutdown();
-        } else {
-
+        if (info.type == CommandType.PEEK) {
+            new PrepareToClose();
+        } else if (info.type == CommandType.TAKE){
+            new ReceiveCloseMessage(CommandType.PEEK);
         }
-
-
-        new ReceiveCloseMessage();
     }
 
 }