ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [6/6] incubator-ignite git commit: # IGNITE-262 - Fixes
Date Mon, 16 Feb 2015 04:22:29 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/2d20498d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/2d20498d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/2d20498d

Branch: refs/heads/sprint-1
Commit: 2d20498d2eb2b7210b68dbc25e84fd741d645368
Parents: 7b0466e
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Sun Feb 15 19:48:49 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Sun Feb 15 19:48:49 2015 -0800

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryManager.java       | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2d20498d/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 825f641..b688919 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
@@ -416,6 +416,9 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K
                         }
 
                         @Override public CacheEntryEvent<? extends K, ? extends V>
next() {
+                            if (!hasNext())
+                                throw new NoSuchElementException();
+
                             CacheEntryEvent<? extends K, ? extends V> next0 = next;
 
                             advance();


Mime
View raw message