ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [09/16] incubator-ignite git commit: # sprint-2 minor
Date Tue, 17 Mar 2015 00:08:05 GMT
# sprint-2  minor


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

Branch: refs/heads/ignite-sql-tests
Commit: c72a45875b55de9f49375070ad3821a9138458bc
Parents: 50171ea
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Mar 16 17:00:33 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Mar 16 17:00:33 2015 +0300

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


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c72a4587/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
index 1cd549a..c475a30 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
@@ -151,6 +151,9 @@ class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
{
         assert routineId != null;
         assert ctx != null;
 
+        if (ctx.cache().internalCache(cacheName) == null)
+            return false;
+
         if (locLsnr != null)
             ctx.resource().injectGeneric(locLsnr);
 


Mime
View raw message