Do not need process missed handler error on stopping node.
@@ -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,7 +354,7 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
if (log.isDebugEnabled())
log.debug(msg0.toString());
}
- else
+ else {
U.error(log, msg0.toString());
try {
@@ -365,7 +364,10 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
}
catch (Exception e) {
U.error(log, "Failed to process failed message: " + e, e);
- }return;
+ }
+ }
+
+ return;
}
onMessage0(nodeId, cacheMsg, c);
