Repository: ignite Updated Branches: refs/heads/ignite-2004 7adb618b1 -> cd90d65d7
IGNITE-2004 Fixed review notes. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cd90d65d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cd90d65d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cd90d65d Branch: refs/heads/ignite-2004 Commit: cd90d65d7bf76b2613200379428d2bc70f737ed6 Parents: 7adb618 Author: nikolay_tikhonov <[email protected]> Authored: Mon Apr 11 19:28:16 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Mon Apr 11 19:28:16 2016 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryManager.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/cd90d65d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java index 3a5e891..48b2546 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java @@ -295,9 +295,12 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter { boolean hasNewVal = newVal != null; boolean hasOldVal = oldVal != null; - if (!hasNewVal && !hasOldVal) + if (!hasNewVal && !hasOldVal) { skipUpdateEvent(lsnrCol, key, partId, updateCntr, primary, topVer); + return; + } + EventType evtType = !hasNewVal ? REMOVED : !hasOldVal ? CREATED : UPDATED; boolean initialized = false;
