Refactoring

src/main/java/org/redisson/client/handler/RedisEncoder.java

@@ -16,6 +16,7 @@
 package org.redisson.client.handler;
 
 import org.redisson.client.protocol.Encoder;
+import org.redisson.client.protocol.StringParamsEncoder;
 import org.redisson.client.protocol.RedisCommand.ValueType;
 
 import io.netty.buffer.ByteBuf;
@@ -25,6 +26,8 @@
 
 public class RedisEncoder extends MessageToByteEncoder<RedisData<Object, Object>> {
 
+    private final Encoder paramsEncoder = new StringParamsEncoder();
+
     final char ARGS_PREFIX = '*';
     final char BYTES_PREFIX = '$';
     final byte[] CRLF = "\r\n".getBytes();
@@ -45,7 +48,7 @@ protected void encode(ChannelHandlerContext ctx, RedisData<Object, Object> msg,
         }
         int i = 1;
         for (Object param : msg.getParams()) {
-            Encoder encoder = msg.getCommand().getParamsEncoder();
+            Encoder encoder = paramsEncoder;
             if (msg.getCommand().getInParamType().size() == 1) {
                 if (msg.getCommand().getInParamIndex() == i && msg.getCommand().getInParamType().get(0) == ValueType.OBJECT) {
                     encoder = msg.getCodec().getValueEncoder();

src/main/java/org/redisson/client/protocol/RedisCommand.java

@@ -31,7 +31,6 @@ public enum ValueType {OBJECT, MAP_VALUE, MAP_KEY, MAP}
     private final String name;
     private final String subName;
 
-    private Encoder paramsEncoder = new StringParamsEncoder();
     private MultiDecoder<R> replayMultiDecoder;
     private Decoder<R> replayDecoder;
     private Convertor<R> convertor = new EmptyConvertor<R>();
@@ -172,10 +171,6 @@ public Convertor<R> getConvertor() {
         return convertor;
     }
 
-    public Encoder getParamsEncoder() {
-        return paramsEncoder;
-    }
-
     public List<ValueType> getInParamType() {
         return inParamType;
     }