ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [1/7] incubator-ignite git commit: #ignite-994: inject ignite before using.
Date Fri, 12 Jun 2015 10:39:21 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-gg-10404 32697ab08 -> c62c410bc


#ignite-994: inject ignite before using.


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

Branch: refs/heads/ignite-gg-10404
Commit: 5db097342411abe6dbdd3d1f9c70029b3b497aff
Parents: 8f455a9
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Wed Jun 10 15:38:17 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Wed Jun 10 15:38:17 2015 +0300

----------------------------------------------------------------------
 .../continuous/GridContinuousProcessor.java          | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5db09734/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
index 38d970b..dd04bf4 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
@@ -343,16 +343,19 @@ public class GridContinuousProcessor extends GridProcessorAdapter {
 
         if (!ctx.isDaemon() && data != null) {
             for (DiscoveryDataItem item : data.items) {
-                // Register handler only if local node passes projection predicate.
-                if (item.prjPred == null || item.prjPred.apply(ctx.discovery().localNode()))
{
-                    try {
+                try {
+                    if (item.prjPred != null)
+                        ctx.resource().injectGeneric(item.prjPred);
+
+                    // Register handler only if local node passes projection predicate.
+                    if (item.prjPred == null || item.prjPred.apply(ctx.discovery().localNode()))
{
                         if (registerHandler(data.nodeId, item.routineId, item.hnd, item.bufSize,
item.interval,
                             item.autoUnsubscribe, false))
                             item.hnd.onListenerRegistered(item.routineId, ctx);
                     }
-                    catch (IgniteCheckedException e) {
-                        U.error(log, "Failed to register continuous handler.", e);
-                    }
+                }
+                catch (IgniteCheckedException e) {
+                    U.error(log, "Failed to register continuous handler.", e);
                 }
             }
 


Mime
View raw message