Repository: ignite Updated Branches: refs/heads/ignite-2004 3436e1493 -> 6b90d19d7
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/6b90d19d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6b90d19d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6b90d19d Branch: refs/heads/ignite-2004 Commit: 6b90d19d7b8a5ab64ecd4af29e7fbdd5fdcde663 Parents: 3436e14 Author: nikolay_tikhonov <[email protected]> Authored: Wed Apr 13 15:02:32 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Wed Apr 13 15:02:32 2016 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6b90d19d/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 dc6d20e..0f9f5b7 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 @@ -319,7 +319,8 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler if (filter != null) { if (filter instanceof JCacheQueryRemoteFilter) { - ctx.resource().injectGeneric(((JCacheQueryRemoteFilter)filter).impl); + if (((JCacheQueryRemoteFilter)filter).impl != null) + ctx.resource().injectGeneric(((JCacheQueryRemoteFilter)filter).impl); if (!asyncCallback) asyncCallback = ((JCacheQueryRemoteFilter)filter).async();
