ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [40/50] [abbrv] incubator-ignite git commit: # ignite-6
Date Thu, 05 Feb 2015 16:14:35 GMT
# 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-111
Commit: 7a6a96323e17847f58e1e4a3c42fa5fd9c3b300b
Parents: bc9292b
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Feb 5 14:35:49 2015 +0300
Committer: sboikov <sboikov@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} */


Mime
View raw message