From 94a4dc91832f7cd4de64e3f2a32959e2ce082f1d Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 24 Feb 2017 18:45:19 +0300
Subject: [PATCH] Errors handling during RBatch execution

---
 .../java/org/redisson/client/handler/CommandDecoder.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java
index b5024789f..b2411e589 100644
--- a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java
+++ b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java
@@ -184,7 +184,7 @@ public class CommandDecoder extends ReplayingDecoder<State> {
                     CommandsData commandBatch) {
         int i = state().getBatchIndex();
 
-        RedisException error = null;
+        Throwable error = null;
         while (in.writerIndex() > in.readerIndex()) {
             CommandData<Object, Object> cmd = null;
             try {
@@ -192,12 +192,12 @@ public class CommandDecoder extends ReplayingDecoder<State> {
                 state().setBatchIndex(i);
                 cmd = (CommandData<Object, Object>) commandBatch.getCommands().get(i);
                 decode(in, cmd, null, ctx.channel());
-                i++;
-            } catch (IOException e) {
+            } catch (Exception e) {
                 cmd.tryFailure(e);
             }
+            i++;
             if (!cmd.isSuccess()) {
-                error = (RedisException) cmd.cause();
+                error = cmd.cause();
             }
         }