ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [2/2] incubator-ignite git commit: # GG-9614 remote cleanup wip
Date Tue, 12 May 2015 12:43:37 GMT
# GG-9614 remote cleanup wip


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/1359de6f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/1359de6f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/1359de6f

Branch: refs/heads/ignite-gg-9614
Commit: 1359de6fc63e1452e127f87b51a13a9e25663752
Parents: 5799f63
Author: ptupitsyn <ptupitsyn@gridgain.com>
Authored: Tue May 12 15:36:49 2015 +0300
Committer: ptupitsyn <ptupitsyn@gridgain.com>
Committed: Tue May 12 15:36:49 2015 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/internal/GridEventConsumeHandler.java  | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1359de6f/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java
index 42043f0..b02e66f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java
@@ -194,6 +194,9 @@ class GridEventConsumeHandler implements GridContinuousHandler {
 
         if (filter instanceof GridLifecycleAwareEventFilter)
             ((GridLifecycleAwareEventFilter)filter).close();
+
+        if (cb instanceof GridLifecycleAwareLocalEventListener)
+            ((GridLifecycleAwareLocalEventListener)cb).close();
     }
 
     /**


Mime
View raw message