Mercurial > hg > Database > Christie

diff src/main/java/christie/topology/node/PrepareToClose.java @ 133:114e0e5b6564

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix prepartoclose
author akahori
date Tue, 25 Dec 2018 17:10:49 +0900
parents 2e2d761ea806
children e295cb59e514
line wrap: on
line diff
--- a/src/main/java/christie/topology/node/PrepareToClose.java	Tue Dec 25 15:18:35 2018 +0900
+++ b/src/main/java/christie/topology/node/PrepareToClose.java	Tue Dec 25 17:10:49 2018 +0900
@@ -12,9 +12,9 @@
 public class PrepareToClose extends CodeGear {
 
     @Take
-    String _CLOSEMESSAGE;
+    String _CLOSEMESSEAGE;
 
-    @Peek
+    @Take
     List<String> _CLIST;
 
     @Peek
@@ -27,14 +27,13 @@
 
     @Override
     protected void run(CodeGearManager cgm) {
+
         for(String dgmName: _CLIST){
             getDGM(dgmName).shutdown();
-            
+            //_CLIST.remove(dgmName);
         }
 
-        if(_CLIST.isEmpty()) {
-            getLocalDGM().finish();
-        }
+        getLocalDGM().finish();
 
         /*if (_CLIST.contains(_CLOSEMESSEAGE)) {
             _CLIST.remove(_CLOSEMESSEAGE);