# GG-9613: Minors after review.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/2a27fe08 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/2a27fe08 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/2a27fe08 Branch: refs/heads/ignite-gg-9613 Commit: 2a27fe0871134500d25cf19e7ad52f77e3a8f7b8 Parents: 220e6bd Author: vozerov-gridgain <voze...@gridgain.com> Authored: Thu Apr 16 18:14:30 2015 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Thu Apr 16 18:14:30 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/managers/communication/GridIoManager.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2a27fe08/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 2607665..a1a882a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -1395,6 +1395,7 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa closedTopics.add(topic); lsnr = lsnrMap.remove(topic); + rmv = lsnr != null; Map<UUID, GridCommunicationMessageSet> map = msgSetMap.remove(topic); @@ -1469,9 +1470,8 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa if (lsnr instanceof ArrayListener) { - for (GridMessageListener childLsnr : ((ArrayListener)lsnr).arr) { + for (GridMessageListener childLsnr : ((ArrayListener)lsnr).arr) closeListener(childLsnr); - } } else closeListener(lsnr); @@ -1486,6 +1486,7 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa private void closeListener(GridMessageListener lsnr) { if (lsnr instanceof GridUserMessageListener) { GridUserMessageListener userLsnr = (GridUserMessageListener)lsnr; + if (userLsnr.predLsnr instanceof GridCloseableMessageFilter) ((GridCloseableMessageFilter)userLsnr.predLsnr).onClose(); }
