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 <[email protected]> Authored: Mon Feb 15 17:24:55 2016 +0300 Committer: sboikov <[email protected]> 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); }
