# ignite-6
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7a6a9632 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7a6a9632 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7a6a9632 Branch: refs/heads/ignite-sql-tests Commit: 7a6a96323e17847f58e1e4a3c42fa5fd9c3b300b Parents: bc9292b Author: sboikov <sboi...@gridgain.com> Authored: Thu Feb 5 14:35:49 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Feb 5 14:35:49 2015 +0300 ---------------------------------------------------------------------- .../cache/datastructures/CacheDataStructuresManager.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7a6a9632/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java index 5826a12..5f68a7a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/datastructures/CacheDataStructuresManager.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.cache.datastructures; import org.apache.ignite.*; import org.apache.ignite.cache.*; +import org.apache.ignite.cache.query.*; import org.apache.ignite.cluster.*; import org.apache.ignite.internal.*; import org.apache.ignite.internal.processors.cache.*; @@ -189,7 +190,7 @@ public class CacheDataStructuresManager<K, V> extends GridCacheManagerAdapter<K, if (queueQryGuard.compareAndSet(false, true)) { queueQry = (GridCacheContinuousQueryAdapter)cctx.cache().queries().createContinuousQuery(); - queueQry.filter(new QueueHeaderPredicate()); + queueQry.remoteFilter(new QueueHeaderPredicate()); queueQry.localCallback(new IgniteBiPredicate<UUID, Collection<GridCacheContinuousQueryEntry>>() { @Override public boolean apply(UUID id, Collection<GridCacheContinuousQueryEntry> entries) { @@ -543,7 +544,7 @@ public class CacheDataStructuresManager<K, V> extends GridCacheManagerAdapter<K, /** * Predicate for queue continuous query. */ - private static class QueueHeaderPredicate implements IgniteBiPredicate, Externalizable { + private static class QueueHeaderPredicate implements IgnitePredicate<CacheContinuousQueryEntry>, Externalizable { /** */ private static final long serialVersionUID = 0L; @@ -555,8 +556,8 @@ public class CacheDataStructuresManager<K, V> extends GridCacheManagerAdapter<K, } /** {@inheritDoc} */ - @Override public boolean apply(Object key, Object val) { - return key instanceof GridCacheQueueHeaderKey; + @Override public boolean apply(CacheContinuousQueryEntry e) { + return e.getKey() instanceof GridCacheQueueHeaderKey; } /** {@inheritDoc} */
