#ignite-525: U.convertException(e) to GridCacheUtils.convertToCacheException(e)
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/0d8ec47b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/0d8ec47b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/0d8ec47b Branch: refs/heads/ignite-45 Commit: 0d8ec47b9231671b40369a800b9f9b9452a40c65 Parents: e6fbedf Author: ivasilinets <ivasilin...@gridgain.com> Authored: Fri Mar 20 17:40:13 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Fri Mar 20 17:40:13 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/datastreamer/DataStreamerImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0d8ec47b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java index 46da1ef..9d6bd62 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java @@ -752,7 +752,7 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed doFlush(); } catch (IgniteCheckedException e) { - throw U.convertException(e); + throw GridCacheUtils.convertToCacheException(e); } finally { leaveBusy(); @@ -777,7 +777,7 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed lastFlushTime = U.currentTimeMillis(); } catch (IgniteInterruptedCheckedException e) { - throw U.convertException(e); + throw GridCacheUtils.convertToCacheException(e); } finally { leaveBusy(); @@ -793,7 +793,7 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed closeEx(cancel); } catch (IgniteCheckedException e) { - throw U.convertException(e); + throw GridCacheUtils.convertToCacheException(e); } }
