# HG changeset patch # User akahori # Date 1545725449 -32400 # Node ID 114e0e5b6564e8d1590c442428d6a2cffc9ccecf # Parent 080c9bb8dcfbbcd459dd310af2050752df95e0be fix prepartoclose diff -r 080c9bb8dcfb -r 114e0e5b6564 src/main/java/christie/topology/node/PrepareToClose.java --- 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 _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);