ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [5/6] incubator-ignite git commit: # IGNITE-262 - Fixes
Date Mon, 16 Feb 2015 04:22:28 GMT
# IGNITE-262 - Fixes


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7b0466e5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7b0466e5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7b0466e5

Branch: refs/heads/sprint-1
Commit: 7b0466e55ce1ac2fd7be92b4a01eb7fd31a9a5f2
Parents: 21b5e38
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Sun Feb 15 19:46:06 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Sun Feb 15 19:46:06 2015 -0800

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryManager.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7b0466e5/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 1347758..825f641 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
@@ -412,7 +412,7 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K
                         }
 
                         @Override public boolean hasNext() {
-                            return it.hasNext();
+                            return next != null;
                         }
 
                         @Override public CacheEntryEvent<? extends K, ? extends V>
next() {


Mime
View raw message