You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/02/15 15:25:31 UTC
[22/22] ignite git commit: ignite-2515 Review.
ignite-2515 Review.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1bfd9e47
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1bfd9e47
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1bfd9e47
Branch: refs/heads/ignite-2515
Commit: 1bfd9e4705e0cd448cc85a0e2f50d99e2ae10971
Parents: 1a65aa1
Author: sboikov <sb...@gridgain.com>
Authored: Mon Feb 15 17:24:55 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Mon Feb 15 17:24:55 2016 +0300
----------------------------------------------------------------------
.../cache/query/continuous/CacheContinuousQueryHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1bfd9e47/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
index ec35b9b..267948d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
@@ -325,9 +325,9 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
// skipPrimaryCheck is set only when listen locally for replicated cache events.
assert !skipPrimaryCheck || (cctx.isReplicated() && ctx.localNodeId().equals(nodeId));
- boolean notify = true;
+ boolean notify = !evt.entry().isFiltered();
- if (!evt.entry().isFiltered() && rmtFilter != null) {
+ if (notify && rmtFilter != null) {
try {
notify = rmtFilter.evaluate(evt);
}