diff --git a/pom.xml b/pom.xml
index 72fe136..22030f3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -51,7 +51,7 @@
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <redisson.version>3.13.4</redisson.version>
+        <redisson.version>3.16.6</redisson.version>
         <junit.version>5.6.2</junit.version>
         <java.version>1.8</java.version>
         <maven-source-plugin.version>3.0.1</maven-source-plugin.version>
diff --git a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/client/RedisAIClient.java b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/client/RedisAIClient.java
index 9db59f6..bd03fc2 100644
--- a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/client/RedisAIClient.java
+++ b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/client/RedisAIClient.java
@@ -32,11 +32,11 @@ public RedisAIClient(Config config) {
     }
 
     public RedisAI getRedisAI() {
-        return new RedisAI(getConnectionManager().getCommandExecutor());
+        return new RedisAI(getCommandExecutor());
     }
 
     public Void flushall() {
-        CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();
+        CommandAsyncExecutor commandExecutor = getCommandExecutor();
         return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
     }
 }
diff --git a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ModelDecoder.java b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ModelDecoder.java
index 79880af..4417e49 100644
--- a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ModelDecoder.java
+++ b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ModelDecoder.java
@@ -20,18 +20,12 @@
 import io.github.dengliming.redismodule.redisai.Device;
 import io.github.dengliming.redismodule.redisai.model.Model;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
 
 public class ModelDecoder implements MultiDecoder<Model> {
 
-    @Override
-    public Decoder<Object> getDecoder(int i, State state) {
-        return null;
-    }
-
     @Override
     public Model decode(List<Object> list, State state) {
         Backend backend = null;
diff --git a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ScriptDecoder.java b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ScriptDecoder.java
index 53d1f51..91fae41 100644
--- a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ScriptDecoder.java
+++ b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/ScriptDecoder.java
@@ -19,18 +19,12 @@
 import io.github.dengliming.redismodule.redisai.Device;
 import io.github.dengliming.redismodule.redisai.model.Script;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
 
 public class ScriptDecoder implements MultiDecoder<Script> {
 
-    @Override
-    public Decoder<Object> getDecoder(int i, State state) {
-        return null;
-    }
-
     @Override
     public Script decode(List<Object> list, State state) {
         String source = null;
diff --git a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/TensorDecoder.java b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/TensorDecoder.java
index 74135fc..1102005 100644
--- a/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/TensorDecoder.java
+++ b/redisai/src/main/java/io/github/dengliming/redismodule/redisai/protocol/decoder/TensorDecoder.java
@@ -19,18 +19,12 @@
 import io.github.dengliming.redismodule.redisai.DataType;
 import io.github.dengliming.redismodule.redisai.model.Tensor;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
 
 public class TensorDecoder implements MultiDecoder<Tensor> {
 
-    @Override
-    public Decoder<Object> getDecoder(int i, State state) {
-        return null;
-    }
-
     @Override
     public Tensor decode(List<Object> list, State state) {
         DataType dataType = null;
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/client/RedisBloomClient.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/client/RedisBloomClient.java
index 47ae5a6..efb20ef 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/client/RedisBloomClient.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/client/RedisBloomClient.java
@@ -36,27 +36,27 @@ public RedisBloomClient(Config config) {
     }
 
     public BloomFilter getRBloomFilter(String name) {
-        return new BloomFilter(getConnectionManager().getCommandExecutor(), name);
+        return new BloomFilter(getCommandExecutor(), name);
     }
 
     public CountMinSketch getCountMinSketch(String name) {
-        return new CountMinSketch(getConnectionManager().getCommandExecutor(), name);
+        return new CountMinSketch(getCommandExecutor(), name);
     }
 
     public CuckooFilter getCuckooFilter(String name) {
-        return new CuckooFilter(getConnectionManager().getCommandExecutor(), name);
+        return new CuckooFilter(getCommandExecutor(), name);
     }
 
     public TopKFilter getTopKFilter(String name) {
-        return new TopKFilter(getConnectionManager().getCommandExecutor(), name);
+        return new TopKFilter(getCommandExecutor(), name);
     }
 
     public TDigest getTDigest(String name) {
-        return new TDigest(getConnectionManager().getCommandExecutor(), name);
+        return new TDigest(getCommandExecutor(), name);
     }
 
     public Void flushall() {
-        CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();
+        CommandAsyncExecutor commandExecutor = getCommandExecutor();
         return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
     }
 }
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/BloomFilterDecoder.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/BloomFilterDecoder.java
index c319e57..5239f2e 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/BloomFilterDecoder.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/BloomFilterDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redisbloom.model.BloomFilterInfo;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
@@ -28,11 +27,6 @@
  */
 public class BloomFilterDecoder implements MultiDecoder<BloomFilterInfo> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public BloomFilterInfo decode(List<Object> parts, State state) {
         return new BloomFilterInfo(((Long) parts.get(1)).intValue(), ((Long) parts.get(3)).intValue(),
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/ChunksDecoder.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/ChunksDecoder.java
index b017ee1..eaa6d62 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/ChunksDecoder.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/ChunksDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redisbloom.model.ChunksData;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
@@ -28,11 +27,6 @@
  */
 public class ChunksDecoder implements MultiDecoder<ChunksData> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public ChunksData decode(List<Object> parts, State state) {
         return new ChunksData(((Long) parts.get(0)).intValue(), (byte[]) parts.get(1));
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CountMinSketchDecoder.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CountMinSketchDecoder.java
index 3e2e41b..9613821 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CountMinSketchDecoder.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CountMinSketchDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redisbloom.model.CountMinSketchInfo;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
@@ -28,11 +27,6 @@
  */
 public class CountMinSketchDecoder implements MultiDecoder<CountMinSketchInfo> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public CountMinSketchInfo decode(List<Object> parts, State state) {
         return new CountMinSketchInfo(((Long) parts.get(1)).intValue(),
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CuckooFilterDecoder.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CuckooFilterDecoder.java
index 4e4582d..ab10219 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CuckooFilterDecoder.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/CuckooFilterDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redisbloom.model.CuckooFilterInfo;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
@@ -28,11 +27,6 @@
  */
 public class CuckooFilterDecoder implements MultiDecoder<CuckooFilterInfo> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public CuckooFilterInfo decode(List<Object> parts, State state) {
         return new CuckooFilterInfo(((Long) parts.get(1)).intValue(), ((Long) parts.get(3)).intValue(), ((Long) parts.get(5)).intValue(),
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TDigestDecoder.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TDigestDecoder.java
index 482ba22..5850428 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TDigestDecoder.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TDigestDecoder.java
@@ -18,18 +18,12 @@
 
 import io.github.dengliming.redismodule.redisbloom.model.TDigestInfo;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
 
 public class TDigestDecoder implements MultiDecoder<TDigestInfo> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public TDigestInfo decode(List<Object> parts, State state) {
         return new TDigestInfo((Long) parts.get(1), (Long) parts.get(3), (Long) parts.get(5), (Long) parts.get(7),
diff --git a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TopKFilterDecoder.java b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TopKFilterDecoder.java
index 3d4a81b..b1d8e6a 100644
--- a/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TopKFilterDecoder.java
+++ b/redisbloom/src/main/java/io/github/dengliming/redismodule/redisbloom/protocol/decoder/TopKFilterDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redisbloom.model.TopKFilterInfo;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.List;
@@ -28,11 +27,6 @@
  */
 public class TopKFilterDecoder implements MultiDecoder<TopKFilterInfo> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public TopKFilterInfo decode(List<Object> parts, State state) {
         return new TopKFilterInfo(((Long) parts.get(1)).intValue(), ((Long) parts.get(3)).intValue(),
diff --git a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/client/RediSearchClient.java b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/client/RediSearchClient.java
index f3cc0de..ef1f7d4 100644
--- a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/client/RediSearchClient.java
+++ b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/client/RediSearchClient.java
@@ -32,11 +32,11 @@ public RediSearchClient(Config config) {
     }
 
     public RediSearch getRediSearch(String name) {
-        return new RediSearch(getConnectionManager().getCommandExecutor(), name);
+        return new RediSearch(getCommandExecutor(), name);
     }
 
     public Void flushall() {
-        CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();
+        CommandAsyncExecutor commandExecutor = getCommandExecutor();
         return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
     }
 }
diff --git a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/AggregateDecoder.java b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/AggregateDecoder.java
index c2f6bb5..a2adfd5 100644
--- a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/AggregateDecoder.java
+++ b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/AggregateDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redisearch.aggregate.AggregateResult;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.ArrayList;
@@ -30,11 +29,6 @@
  */
 public class AggregateDecoder implements MultiDecoder<AggregateResult> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public AggregateResult decode(List<Object> parts, State state) {
         AggregateResult aggregateResult = new AggregateResult();
diff --git a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/MisspelledTermDecoder.java b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/MisspelledTermDecoder.java
index e2976c1..95f01bc 100644
--- a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/MisspelledTermDecoder.java
+++ b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/MisspelledTermDecoder.java
@@ -19,7 +19,6 @@
 import io.github.dengliming.redismodule.redisearch.search.MisspelledSuggestion;
 import io.github.dengliming.redismodule.redisearch.search.MisspelledTerm;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.ArrayList;
@@ -30,11 +29,6 @@
  */
 public class MisspelledTermDecoder implements MultiDecoder<MisspelledTerm> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public MisspelledTerm decode(List<Object> parts, State state) {
         if (parts == null || parts.size() < 3) {
diff --git a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/SearchResultDecoder.java b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/SearchResultDecoder.java
index bf624d1..9f09b0c 100644
--- a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/SearchResultDecoder.java
+++ b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/SearchResultDecoder.java
@@ -19,7 +19,6 @@
 import io.github.dengliming.redismodule.redisearch.index.Document;
 import io.github.dengliming.redismodule.redisearch.search.SearchResult;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.ArrayList;
@@ -40,11 +39,6 @@ public SearchResultDecoder(boolean withScores) {
         this.withScores = withScores;
     }
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public SearchResult decode(List<Object> parts, State state) {
         Long total = (Long) parts.get(0);
diff --git a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/StringMapInfoDecoder.java b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/StringMapInfoDecoder.java
index 75a06a6..a665892 100644
--- a/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/StringMapInfoDecoder.java
+++ b/redisearch/src/main/java/io/github/dengliming/redismodule/redisearch/protocol/decoder/StringMapInfoDecoder.java
@@ -17,7 +17,6 @@
 package io.github.dengliming.redismodule.redisearch.protocol.decoder;
 
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.LinkedHashMap;
@@ -29,11 +28,6 @@
  */
 public class StringMapInfoDecoder implements MultiDecoder<Map<String, Object>> {
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     @Override
     public Map<String, Object> decode(List<Object> parts, State state) {
         Map<String, Object> fields = new LinkedHashMap<>(parts.size() / 2);
diff --git a/redisgears/src/main/java/io/github/dengliming/redismodule/redisgears/client/RedisGearsClient.java b/redisgears/src/main/java/io/github/dengliming/redismodule/redisgears/client/RedisGearsClient.java
index 7f32fd0..36835a8 100644
--- a/redisgears/src/main/java/io/github/dengliming/redismodule/redisgears/client/RedisGearsClient.java
+++ b/redisgears/src/main/java/io/github/dengliming/redismodule/redisgears/client/RedisGearsClient.java
@@ -29,11 +29,11 @@ public RedisGearsClient(Config config) {
     }
 
     public RedisGears getRedisGears() {
-        return new RedisGears(getConnectionManager().getCommandExecutor());
+        return new RedisGears(getCommandExecutor());
     }
 
     public Void flushall() {
-        CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();
+        CommandAsyncExecutor commandExecutor = getCommandExecutor();
         return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
     }
 }
diff --git a/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/client/RedisJSONClient.java b/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/client/RedisJSONClient.java
index 5c95330..855bc8c 100644
--- a/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/client/RedisJSONClient.java
+++ b/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/client/RedisJSONClient.java
@@ -29,11 +29,11 @@ public RedisJSONClient(Config config) {
     }
 
     public RedisJSON getRedisJSON() {
-        return new RedisJSON(getConnectionManager().getCommandExecutor());
+        return new RedisJSON(getCommandExecutor());
     }
 
     public Void flushall() {
-        CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();
+        CommandAsyncExecutor commandExecutor = getCommandExecutor();
         return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
     }
 }
diff --git a/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/protocol/RedisCommands.java b/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/protocol/RedisCommands.java
index 9cceb25..cb93a82 100644
--- a/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/protocol/RedisCommands.java
+++ b/redisjson/src/main/java/io/github/dengliming/redismodule/redisjson/protocol/RedisCommands.java
@@ -18,6 +18,7 @@
 
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.convertor.LongReplayConvertor;
+import org.redisson.client.protocol.decoder.ObjectDecoder;
 import org.redisson.client.protocol.decoder.ObjectListReplayDecoder;
 import org.redisson.client.protocol.decoder.StringDataDecoder;
 import org.redisson.client.protocol.decoder.StringReplayDecoder;
@@ -28,12 +29,12 @@
 public interface RedisCommands {
 
     RedisCommand JSON_DEL = new RedisCommand<>("JSON.DEL", new LongReplayConvertor());
-    RedisCommand JSON_SET = new RedisCommand<>("JSON.SET", new StringReplayDecoder());
-    RedisCommand JSON_GET = new RedisCommand<>("JSON.GET", new StringDataDecoder());
-    RedisCommand JSON_TYPE = new RedisCommand<>("JSON.TYPE", new StringDataDecoder());
+    RedisCommand JSON_SET = new RedisCommand<>("JSON.SET", new ObjectDecoder(new StringReplayDecoder()));
+    RedisCommand JSON_GET = new RedisCommand<>("JSON.GET", new ObjectDecoder(new StringDataDecoder()));
+    RedisCommand JSON_TYPE = new RedisCommand<>("JSON.TYPE", new ObjectDecoder(new StringDataDecoder()));
     RedisCommand JSON_MGET = new RedisCommand<>("JSON.MGET", new ObjectListReplayDecoder<String>());
-    RedisCommand JSON_NUMINCRBY = new RedisCommand<>("JSON.NUMINCRBY", new StringDataDecoder());
-    RedisCommand JSON_NUMMULTBY = new RedisCommand<>("JSON.NUMMULTBY", new StringDataDecoder());
+    RedisCommand JSON_NUMINCRBY = new RedisCommand<>("JSON.NUMINCRBY", new ObjectDecoder(new StringDataDecoder()));
+    RedisCommand JSON_NUMMULTBY = new RedisCommand<>("JSON.NUMMULTBY", new ObjectDecoder(new StringDataDecoder()));
     RedisCommand JSON_STRAPPEND = new RedisCommand<>("JSON.STRAPPEND", new LongReplayConvertor());
     RedisCommand JSON_STRLEN = new RedisCommand<>("JSON.STRLEN", new LongReplayConvertor());
     RedisCommand JSON_ARRAPPEND = new RedisCommand<>("JSON.ARRAPPEND", new LongReplayConvertor());
@@ -41,5 +42,5 @@ public interface RedisCommands {
     RedisCommand JSON_ARRTRIM = new RedisCommand<>("JSON.ARRTRIM", new LongReplayConvertor());
     RedisCommand JSON_ARRINSERT = new RedisCommand<>("JSON.ARRINSERT", new LongReplayConvertor());
     RedisCommand JSON_ARRINDEX = new RedisCommand<>("JSON.ARRINDEX", new LongReplayConvertor());
-    RedisCommand JSON_ARRPOP = new RedisCommand<>("JSON.ARRPOP", new StringDataDecoder());
+    RedisCommand JSON_ARRPOP = new RedisCommand<>("JSON.ARRPOP", new ObjectDecoder(new StringDataDecoder()));
 }
diff --git a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/client/RedisTimeSeriesClient.java b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/client/RedisTimeSeriesClient.java
index 55446ca..3d77783 100644
--- a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/client/RedisTimeSeriesClient.java
+++ b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/client/RedisTimeSeriesClient.java
@@ -32,11 +32,11 @@ public RedisTimeSeriesClient(Config config) {
     }
 
     public RedisTimeSeries getRedisTimeSeries() {
-        return new RedisTimeSeries(getConnectionManager().getCommandExecutor());
+        return new RedisTimeSeries(getCommandExecutor());
     }
 
     public Void flushall() {
-        CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();
+        CommandAsyncExecutor commandExecutor = getCommandExecutor();
         return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
     }
 }
diff --git a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/LabelDecoder.java b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/LabelDecoder.java
index d658684..a2c6cc0 100644
--- a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/LabelDecoder.java
+++ b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/LabelDecoder.java
@@ -18,7 +18,6 @@
 
 import io.github.dengliming.redismodule.redistimeseries.Label;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
 
 import java.util.ArrayList;
@@ -28,10 +27,6 @@
  * @author dengliming
  */
 public class LabelDecoder implements MultiDecoder<List<Label>> {
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
 
     /**
      * [[label1, test], [label2, test1]]
diff --git a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/TimeSeriesDecoder.java b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/TimeSeriesDecoder.java
index 5e60fd6..50f3ab9 100644
--- a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/TimeSeriesDecoder.java
+++ b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/TimeSeriesDecoder.java
@@ -18,12 +18,13 @@
 
 import io.github.dengliming.redismodule.redistimeseries.TimeSeries;
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
-import static io.github.dengliming.redismodule.redistimeseries.Sample.Value;
+
 import java.util.ArrayList;
 import java.util.List;
 
+import static io.github.dengliming.redismodule.redistimeseries.Sample.Value;
+
 /**
  * @author dengliming
  */
@@ -32,11 +33,6 @@ public class TimeSeriesDecoder implements MultiDecoder<List<TimeSeries>> {
     private LabelDecoder labelDecoder = new LabelDecoder();
     private ValueDecoder valueDecoder = new ValueDecoder();
 
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
-
     /**
      * [temperature:2:33, [[label1, test], [label2, test1]], [1588266627081, 13]]
      *
diff --git a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/ValueDecoder.java b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/ValueDecoder.java
index f401b19..343eca4 100644
--- a/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/ValueDecoder.java
+++ b/redistimeseries/src/main/java/io/github/dengliming/redismodule/redistimeseries/protocol/decoder/ValueDecoder.java
@@ -17,20 +17,16 @@
 package io.github.dengliming.redismodule.redistimeseries.protocol.decoder;
 
 import org.redisson.client.handler.State;
-import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.decoder.MultiDecoder;
-import static io.github.dengliming.redismodule.redistimeseries.Sample.Value;
 
 import java.util.List;
 
+import static io.github.dengliming.redismodule.redistimeseries.Sample.Value;
+
 /**
  * @author dengliming
  */
 public class ValueDecoder implements MultiDecoder<Value> {
-    @Override
-    public Decoder<Object> getDecoder(int paramNum, State state) {
-        return null;
-    }
 
     @Override
     public Value decode(List<Object> parts, State state) {