# 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 <vkuliche...@gridgain.com>
Authored: Sun Feb 15 19:46:06 2015 -0800
Committer: Valentin Kulichenko <vkuliche...@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() {

Reply via email to