You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2015/03/04 02:31:55 UTC
[25/50] [abbrv] incubator-ignite git commit: # sprint-1 Ignore
exception from user cache listener
# 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 <sb...@gridgain.com>
Authored: Mon Feb 16 16:15:08 2015 +0300
Committer: sboikov <sb...@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);
}
}
}