Repository: ignite Updated Branches: refs/heads/ignite-3004 fab4fdb3e -> 3812a4b2c
IGNITE-3004 WIP. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3812a4b2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3812a4b2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3812a4b2 Branch: refs/heads/ignite-3004 Commit: 3812a4b2c85b03571b57a98204c3f01734715166 Parents: fab4fdb Author: nikolay_tikhonov <[email protected]> Authored: Fri Apr 22 11:41:47 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Fri Apr 22 11:41:47 2016 +0300 ---------------------------------------------------------------------- .../continuous/CacheContinuousQueryHandler.java | 42 ++++++++++---------- 1 file changed, 21 insertions(+), 21 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3812a4b2/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 b0f4d62..b29f7cb 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 @@ -787,27 +787,27 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler U.error(ctx.log(getClass()), "Failed to send event notification to node: " + nodeId, ex); } - if (recordIgniteEvt && notify) { - ctx.event().record(new CacheQueryReadEvent<>( - ctx.discovery().localNode(), - "Continuous query executed.", - EVT_CACHE_QUERY_OBJECT_READ, - CacheQueryType.CONTINUOUS.name(), - cacheName, - null, - null, - null, - getEventFilter() instanceof CacheEntryEventSerializableFilter ? - (CacheEntryEventSerializableFilter)getEventFilter() : null, - null, - nodeId, - taskName(), - evt.getKey(), - evt.getValue(), - evt.getOldValue(), - null - )); - } +// if (recordIgniteEvt && notify) { +// ctx.event().record(new CacheQueryReadEvent<>( +// ctx.discovery().localNode(), +// "Continuous query executed.", +// EVT_CACHE_QUERY_OBJECT_READ, +// CacheQueryType.CONTINUOUS.name(), +// cacheName, +// null, +// null, +// null, +// getEventFilter() instanceof CacheEntryEventSerializableFilter ? +// (CacheEntryEventSerializableFilter)getEventFilter() : null, +// null, +// nodeId, +// taskName(), +// evt.getKey(), +// evt.getValue(), +// evt.getOldValue(), +// null +// )); +// } } /**
