Do not need process missed handler error on stopping node.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f6f5e494 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f6f5e494 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f6f5e494 Branch: refs/heads/ignite-2.1.2-exchange Commit: f6f5e49413072a74c3712f3fba03946807ff58c7 Parents: 6143bc9 Author: sboikov <[email protected]> Authored: Mon Jun 19 17:52:08 2017 +0300 Committer: sboikov <[email protected]> Committed: Mon Jun 19 17:52:08 2017 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheIoManager.java | 20 +++++++++++--------- 1 file changed, 11 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f6f5e494/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java index 2be3df4..010723d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java @@ -25,7 +25,6 @@ import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.UUID; -import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; @@ -355,18 +354,21 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { if (log.isDebugEnabled()) log.debug(msg0.toString()); } - else + else { U.error(log, msg0.toString()); - try { - cacheMsg.onClassError(new IgniteCheckedException("Failed to find message handler for message: " + cacheMsg)); + try { + cacheMsg.onClassError(new IgniteCheckedException("Failed to find message handler for message: " + cacheMsg)); - processFailedMessage(nodeId, cacheMsg, c); + processFailedMessage(nodeId, cacheMsg, c); + } + catch (Exception e) { + U.error(log, "Failed to process failed message: " + e, e); + } + } + + return; } - catch (Exception e) { - U.error(log, "Failed to process failed message: " + e, e); - }return; - } onMessage0(nodeId, cacheMsg, c); }
