Mercurial > hg > Database > Christie

diff src/main/java/christie/topology/node/PrepareToClose.java @ 129:2e2d761ea806

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