ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [34/47] ignite git commit: IGNITE-5729 Correct handling CacheStoppedException in IgniteCacheProxyImpl.
Date Tue, 01 Aug 2017 09:26:17 GMT
IGNITE-5729 Correct handling CacheStoppedException in IgniteCacheProxyImpl.


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

Branch: refs/heads/master
Commit: 1b7606ce8beaa42bc5db740e5af9cb4d98681b4c
Parents: f975110
Author: Pavel Kovalenko <jokserfn@gmail.com>
Authored: Fri Jul 28 17:13:30 2017 +0300
Committer: Pavel Kovalenko <jokserfn@gmail.com>
Committed: Fri Jul 28 17:13:30 2017 +0300

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/IgniteCacheProxyImpl.java    | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1b7606ce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
index 0bc3ba2..f2c2cf7 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
@@ -1657,6 +1657,9 @@ public class IgniteCacheProxyImpl<K, V> extends AsyncSupportAdapter<IgniteCache<
         if (e instanceof IgniteCheckedException)
             return CU.convertToCacheException((IgniteCheckedException) e);
 
+        if (X.hasCause(e, CacheStoppedException.class))
+            return CU.convertToCacheException(X.cause(e, CacheStoppedException.class));
+
         if (e instanceof RuntimeException)
             return (RuntimeException) e;
 


Mime
View raw message