# IGNITE-1097 Wrap RuntimeException to GridClosureException. (cherry picked from commit 6831b30)
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/20841759 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/20841759 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/20841759 Branch: refs/heads/ignite-1056 Commit: 208417597717fce72714bf778296f838074fa4bb Parents: 98c57e0 Author: sevdokimov <sergey.evdoki...@jetbrains.com> Authored: Thu Jul 9 17:25:42 2015 +0300 Committer: sevdokimov <sergey.evdoki...@jetbrains.com> Committed: Fri Jul 10 10:47:45 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/IgniteCacheProxy.java | 29 ++++++++++++++++---- 1 file changed, 23 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/20841759/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java index b31b2e8..00fc0f9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java @@ -28,6 +28,7 @@ import org.apache.ignite.internal.processors.cache.query.*; import org.apache.ignite.internal.processors.query.*; import org.apache.ignite.internal.util.*; import org.apache.ignite.internal.util.future.*; +import org.apache.ignite.internal.util.lang.*; import org.apache.ignite.internal.util.tostring.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; @@ -884,7 +885,12 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V IgniteInternalFuture<Void> fut0 = fut.chain(new CX1<IgniteInternalFuture<Boolean>, Void>() { @Override public Void applyx(IgniteInternalFuture<Boolean> fut) throws IgniteCheckedException { - fut.get(); + try { + fut.get(); + } + catch (RuntimeException e) { + throw new GridClosureException(e); + } return null; } @@ -1238,9 +1244,14 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V IgniteInternalFuture<T> fut0 = fut.chain(new CX1<IgniteInternalFuture<EntryProcessorResult<T>>, T>() { @Override public T applyx(IgniteInternalFuture<EntryProcessorResult<T>> fut) throws IgniteCheckedException { - EntryProcessorResult<T> res = fut.get(); - - return res != null ? res.get() : null; + try { + EntryProcessorResult<T> res = fut.get(); + + return res != null ? res.get() : null; + } + catch (RuntimeException e) { + throw new GridClosureException(e); + } } }); @@ -1276,9 +1287,15 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V IgniteInternalFuture<T> fut0 = fut.chain(new CX1<IgniteInternalFuture<EntryProcessorResult<T>>, T>() { @Override public T applyx(IgniteInternalFuture<EntryProcessorResult<T>> fut) throws IgniteCheckedException { - EntryProcessorResult<T> res = fut.get(); - return res != null ? res.get() : null; + try { + EntryProcessorResult<T> res = fut.get(); + + return res != null ? res.get() : null; + } + catch (RuntimeException e) { + throw new GridClosureException(e); + } } });
