cc
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8cbcef65 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8cbcef65 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8cbcef65 Branch: refs/heads/ignite-5075-cc-debug Commit: 8cbcef657d2958395377654d44779c68ce16fca6 Parents: 79e34c2 Author: sboikov <sboi...@gridgain.com> Authored: Thu May 25 20:33:50 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu May 25 20:33:50 2017 +0300 ---------------------------------------------------------------------- .../apache/ignite/internal/processors/cache/GridCacheMapEntry.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8cbcef65/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java index 30c2a33..80f872c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java @@ -1838,6 +1838,8 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme if (updateRes.success()) updateMetrics(c.op, metrics); + lsnrs = cctx.continuousQueries().updateListeners(internal, false); + // Continuous query filter should be perform under lock. if (lsnrs != null) { CacheObject evtVal = cctx.unwrapTemporary(updateVal);
