Upgrade redisson api version (#33)

dengliming · web-flow · commit 3faf66d45eb9 · 2021-12-22T23:14:00.000+08:00
* Upgrade redisson api version

* fix

* fix

* fix
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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,18 +29,18 @@
 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());
     RedisCommand JSON_ARRLEN = new RedisCommand<>("JSON.ARRLEN", new LongReplayConvertor());
     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
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
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
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

Original file line number	Diff line number	Diff line change
`@@ -32,11 +32,11 @@ public RedisAIClient(Config config) {`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`public RedisAI getRedisAI() {`
`35`		`- return new RedisAI(getConnectionManager().getCommandExecutor());`
	`35`	`+ return new RedisAI(getCommandExecutor());`
`36`	`36`	`}`
`37`	`37`
`38`	`38`	`public Void flushall() {`
`39`		`- CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();`
	`39`	`+ CommandAsyncExecutor commandExecutor = getCommandExecutor();`
`40`	`40`	`return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));`
`41`	`41`	`}`
`42`	`42`	`}`
Original file line number	Diff line number	Diff line change
`@@ -36,27 +36,27 @@ public RedisBloomClient(Config config) {`
`36`	`36`	`}`
`37`	`37`
`38`	`38`	`public BloomFilter getRBloomFilter(String name) {`
`39`		`- return new BloomFilter(getConnectionManager().getCommandExecutor(), name);`
	`39`	`+ return new BloomFilter(getCommandExecutor(), name);`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`public CountMinSketch getCountMinSketch(String name) {`
`43`		`- return new CountMinSketch(getConnectionManager().getCommandExecutor(), name);`
	`43`	`+ return new CountMinSketch(getCommandExecutor(), name);`
`44`	`44`	`}`
`45`	`45`
`46`	`46`	`public CuckooFilter getCuckooFilter(String name) {`
`47`		`- return new CuckooFilter(getConnectionManager().getCommandExecutor(), name);`
	`47`	`+ return new CuckooFilter(getCommandExecutor(), name);`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`public TopKFilter getTopKFilter(String name) {`
`51`		`- return new TopKFilter(getConnectionManager().getCommandExecutor(), name);`
	`51`	`+ return new TopKFilter(getCommandExecutor(), name);`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`public TDigest getTDigest(String name) {`
`55`		`- return new TDigest(getConnectionManager().getCommandExecutor(), name);`
	`55`	`+ return new TDigest(getCommandExecutor(), name);`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`public Void flushall() {`
`59`		`- CommandAsyncExecutor commandExecutor = getConnectionManager().getCommandExecutor();`
	`59`	`+ CommandAsyncExecutor commandExecutor = getCommandExecutor();`
`60`	`60`	`return commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));`
`61`	`61`	`}`
`62`	`62`	`}`