From f99cda5232f67fc5720d8d667a083455e6ed2fcb Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Mon, 21 Dec 2015 15:44:58 +0300
Subject: [PATCH] messageDecoder removed from AsyncDetails

---
 src/main/java/org/redisson/command/AsyncDetails.java        | 2 --
 src/main/java/org/redisson/command/CommandAsyncService.java | 4 ++--
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/redisson/command/AsyncDetails.java b/src/main/java/org/redisson/command/AsyncDetails.java
index 79d4b1d0d..1efef7fa2 100644
--- a/src/main/java/org/redisson/command/AsyncDetails.java
+++ b/src/main/java/org/redisson/command/AsyncDetails.java
@@ -39,7 +39,6 @@ public class AsyncDetails<V, R> {
     Promise<R> attemptPromise;
     boolean readOnlyMode;
     NodeSource source;
-    MultiDecoder<Object> messageDecoder;
     Codec codec;
     RedisCommand<V> command;
     Object[] params;
@@ -78,7 +77,6 @@ public class AsyncDetails<V, R> {
         this.attemptPromise = attemptPromise;
         this.readOnlyMode = readOnlyMode;
         this.source = source;
-        this.messageDecoder = messageDecoder;
         this.codec = codec;
         this.command = command;
         this.params = params;
diff --git a/src/main/java/org/redisson/command/CommandAsyncService.java b/src/main/java/org/redisson/command/CommandAsyncService.java
index 66e4db2fc..d5b38a246 100644
--- a/src/main/java/org/redisson/command/CommandAsyncService.java
+++ b/src/main/java/org/redisson/command/CommandAsyncService.java
@@ -471,13 +471,13 @@ public class CommandAsyncService implements CommandAsyncExecutor {
             List<CommandData<?, ?>> list = new ArrayList<CommandData<?, ?>>(2);
             Promise<Void> promise = connectionManager.newPromise();
             list.add(new CommandData<Void, Void>(promise, details.getCodec(), RedisCommands.ASKING, new Object[] {}));
-            list.add(new CommandData<V, R>(details.getAttemptPromise(), details.getMessageDecoder(), details.getCodec(), details.getCommand(), details.getParams()));
+            list.add(new CommandData<V, R>(details.getAttemptPromise(), details.getCodec(), details.getCommand(), details.getParams()));
             Promise<Void> main = connectionManager.newPromise();
             ChannelFuture future = connection.send(new CommandsData(main, list));
             details.setWriteFuture(future);
         } else {
             log.debug("aquired connection for command {} from slot {} using node {}", details.getCommand(), details.getSource(), connection.getRedisClient().getAddr());
-            ChannelFuture future = connection.send(new CommandData<V, R>(details.getAttemptPromise(), details.getMessageDecoder(), details.getCodec(), details.getCommand(), details.getParams()));
+            ChannelFuture future = connection.send(new CommandData<V, R>(details.getAttemptPromise(), details.getCodec(), details.getCommand(), details.getParams()));
             details.setWriteFuture(future);
         }