ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [25/50] [abbrv] incubator-ignite git commit: # sprint-1 Ignore exception from user cache listener
Date Wed, 04 Mar 2015 01:31:55 GMT
# sprint-1 Ignore exception from user cache listener


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

Branch: refs/heads/master
Commit: 9138bd628a869ff0e9342f738e58880825807f9a
Parents: 19c1b5c
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Feb 16 16:15:08 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Feb 16 16:15:08 2015 +0300

----------------------------------------------------------------------
 .../continuous/CacheContinuousQueryManager.java | 49 ++++++++++++--------
 1 file changed, 30 insertions(+), 19 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9138bd62/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 b688919..fc9811e 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
@@ -596,8 +596,12 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K
         /** */
         private final Cache<K, V> cache;
 
+        /** */
+        private final IgniteLogger log;
+
         /**
          * @param impl Listener.
+         * @param cache Cache.
          */
         JCacheQueryLocalListener(CacheEntryListener<K, V> impl, Cache<K, V> cache)
{
             assert impl != null;
@@ -605,42 +609,49 @@ public class CacheContinuousQueryManager<K, V> extends GridCacheManagerAdapter<K
 
             this.impl = impl;
             this.cache = cache;
+
+            log = cache.unwrap(Ignite.class).log().getLogger(CacheContinuousQueryManager.class);
         }
 
         /** {@inheritDoc} */
         @Override public void onUpdated(Iterable<CacheEntryEvent<? extends K, ? extends
V>> evts) {
             for (CacheEntryEvent<? extends K, ? extends V> evt : evts) {
-                switch (evt.getEventType()) {
-                    case CREATED:
-                        assert impl instanceof CacheEntryCreatedListener;
+                try {
+                    switch (evt.getEventType()) {
+                        case CREATED:
+                            assert impl instanceof CacheEntryCreatedListener;
 
-                        ((CacheEntryCreatedListener<K, V>)impl).onCreated(singleton(evt));
+                            ((CacheEntryCreatedListener<K, V>)impl).onCreated(singleton(evt));
 
-                        break;
+                            break;
 
-                    case UPDATED:
-                        assert impl instanceof CacheEntryUpdatedListener;
+                        case UPDATED:
+                            assert impl instanceof CacheEntryUpdatedListener;
 
-                        ((CacheEntryUpdatedListener<K, V>)impl).onUpdated(singleton(evt));
+                            ((CacheEntryUpdatedListener<K, V>)impl).onUpdated(singleton(evt));
 
-                        break;
+                            break;
 
-                    case REMOVED:
-                        assert impl instanceof CacheEntryRemovedListener;
+                        case REMOVED:
+                            assert impl instanceof CacheEntryRemovedListener;
 
-                        ((CacheEntryRemovedListener<K, V>)impl).onRemoved(singleton(evt));
+                            ((CacheEntryRemovedListener<K, V>)impl).onRemoved(singleton(evt));
 
-                        break;
+                            break;
 
-                    case EXPIRED:
-                        assert impl instanceof CacheEntryExpiredListener;
+                        case EXPIRED:
+                            assert impl instanceof CacheEntryExpiredListener;
 
-                        ((CacheEntryExpiredListener<K, V>)impl).onExpired(singleton(evt));
+                            ((CacheEntryExpiredListener<K, V>)impl).onExpired(singleton(evt));
 
-                        break;
+                            break;
 
-                    default:
-                        throw new IllegalStateException("Unknown type: " + evt.getEventType());
+                        default:
+                            throw new IllegalStateException("Unknown type: " + evt.getEventType());
+                    }
+                }
+                catch (Exception e) {
+                    U.error(log, "CacheEntryCreatedListener failed: " + e);
                 }
             }
         }


Mime
View raw message