messageDecoder removed from AsyncDetails

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;

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);
         }