diff --git a/src/main/java/org/redisson/CommandBatchExecutorService.java b/src/main/java/org/redisson/CommandBatchExecutorService.java
index 263d11aab..564b11337 100644
--- a/src/main/java/org/redisson/CommandBatchExecutorService.java
+++ b/src/main/java/org/redisson/CommandBatchExecutorService.java
@@ -231,7 +231,7 @@ public class CommandBatchExecutorService extends CommandExecutorService {
                     public void operationComplete(ChannelFuture future) throws Exception {
                         if (!future.isSuccess()) {
                             timeout.cancel();
-                            ex.set(new WriteRedisConnectionException("channel: " + future.channel() + " has been closed"));
+                            ex.set(new WriteRedisConnectionException("Can't write commands batch to channel: " + future.channel(), future.cause()));
                             connectionManager.getTimer().newTimeout(retryTimerTask, connectionManager.getConfig().getRetryInterval(), TimeUnit.MILLISECONDS);
                         }
                     }
diff --git a/src/main/java/org/redisson/client/WriteRedisConnectionException.java b/src/main/java/org/redisson/client/WriteRedisConnectionException.java
index 0414a1235..d95fa09ed 100644
--- a/src/main/java/org/redisson/client/WriteRedisConnectionException.java
+++ b/src/main/java/org/redisson/client/WriteRedisConnectionException.java
@@ -19,10 +19,6 @@ public class WriteRedisConnectionException extends RedisException {
 
     private static final long serialVersionUID = -4756928186967834601L;
 
-    public WriteRedisConnectionException(String msg) {
-        super(msg);
-    }
-
     public WriteRedisConnectionException(String msg, Throwable e) {
         super(msg, e);
     }