From 6545025bc87125563db3df362ab136b935e388aa Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 16 Sep 2016 11:17:09 +0300
Subject: [PATCH] Skip some io messages. #617

---
 .../java/org/redisson/client/handler/CommandsQueue.java  | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java b/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java
index 626382ebb..2e61457c5 100644
--- a/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java
+++ b/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java
@@ -15,8 +15,11 @@
  */
 package org.redisson.client.handler;
 
+import java.util.Arrays;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Queue;
+import java.util.Set;
 
 import org.redisson.client.protocol.CommandData;
 import org.redisson.client.protocol.QueueCommand;
@@ -43,6 +46,8 @@ public class CommandsQueue extends ChannelOutboundHandlerAdapter {
 
     private static final Logger log = LoggerFactory.getLogger(CommandsQueue.class);
     
+    private static final Set<String> SKIP_MESSAGES = new HashSet<String>(Arrays.asList("Connection timed out", "Connection reset by peer", "Broken pipe"));
+    
     public static final AttributeKey<QueueCommand> CURRENT_COMMAND = AttributeKey.valueOf("promise");
 
     private final Queue<QueueCommandHolder> queue = PlatformDependent.newMpscQueue();
@@ -109,7 +114,9 @@ public class CommandsQueue extends ChannelOutboundHandlerAdapter {
             return;
         }
         
-        log.error("Exception occured. Channel: " + ctx.channel(), cause);
+        if (!SKIP_MESSAGES.contains(cause.getMessage())) {
+            log.error("Exception occured. Channel: " + ctx.channel(), cause);
+        }
     }
     
 }