Repository: ignite Updated Branches: refs/heads/ignite-1186 ca200fc1b -> 0e6b0b75b
IGNITE-1186 minor fix. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0e6b0b75 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0e6b0b75 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0e6b0b75 Branch: refs/heads/ignite-1186 Commit: 0e6b0b75bc77dbdf33bb389b35c527145a73501c Parents: ca200fc Author: nikolay_tikhonov <[email protected]> Authored: Tue Mar 1 20:09:45 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Tue Mar 1 20:09:45 2016 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0e6b0b75/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 50253fa..353043f 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 @@ -637,7 +637,7 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter { hnd.notifyExisting(notifyExisting); hnd.internal(internal); hnd.keepBinary(keepBinary); - hnd.localCache(loc); + hnd.localCache(cctx.isLocal()); IgnitePredicate<ClusterNode> pred = (loc || cctx.config().getCacheMode() == CacheMode.LOCAL) ? F.nodeForNodeId(cctx.localNodeId()) : F.<ClusterNode>alwaysTrue();
