Errors handling during RBatch execution

redisson · Feb 24, 2017 · 94a4dc9 · 94a4dc9
1 parent 57aea88
commit 94a4dc9
Showing 1 changed file with 4 additions and 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
@@ -184,20 +184,20 @@ private void decodeCommandBatch(ChannelHandlerContext ctx, ByteBuf in, QueueComm
                     CommandsData commandBatch) {
         int i = state().getBatchIndex();
 
-        RedisException error = null;
+        Throwable error = null;
         while (in.writerIndex() > in.readerIndex()) {
             CommandData<Object, Object> cmd = null;
             try {
                 checkpoint();
                 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();
             }
         }