Fix: return of CLUSTER REPLICAS is Array reply (#2990)

not Bulk reply as it as has been stated in the [Redis doc](https://redis.io/commands/cluster-replicas/)
redis · Apr 29, 2022 · 379bbed · 379bbed
1 parent 76764b9
commit 379bbed
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/src/main/java/redis/clients/jedis/Jedis.java b/src/main/java/redis/clients/jedis/Jedis.java
@@ -8581,13 +8581,6 @@ public String clusterNodes() {
     return connection.getBulkReply();
   }
 
-  @Override
-  public String clusterReplicas(final String nodeId) {
-    checkIsInMultiOrPipeline();
-    connection.sendCommand(CLUSTER, ClusterKeyword.REPLICAS.name(), nodeId);
-    return connection.getBulkReply();
-  }
-
   @Override
   public String clusterMeet(final String ip, final int port) {
     checkIsInMultiOrPipeline();
@@ -8743,6 +8736,13 @@ public List<String> clusterSlaves(final String nodeId) {
     return connection.getMultiBulkReply();
   }
 
+  @Override
+  public List<String> clusterReplicas(final String nodeId) {
+    checkIsInMultiOrPipeline();
+    connection.sendCommand(CLUSTER, ClusterKeyword.REPLICAS.name(), nodeId);
+    return connection.getMultiBulkReply();
+  }
+
   @Override
   public String clusterFailover() {
     checkIsInMultiOrPipeline();

diff --git a/src/main/java/redis/clients/jedis/commands/ClusterCommands.java b/src/main/java/redis/clients/jedis/commands/ClusterCommands.java
@@ -16,8 +16,6 @@ public interface ClusterCommands {
 
   String clusterNodes();
 
-  String clusterReplicas(String nodeId);
-
   String clusterMeet(String ip, int port);
 
   String clusterAddSlots(int... slots);
@@ -75,6 +73,8 @@ public interface ClusterCommands {
   @Deprecated
   List<String> clusterSlaves(String nodeId);
 
+  List<String> clusterReplicas(String nodeId);
+
   String clusterFailover();
 
   String clusterFailover(ClusterFailoverOption failoverOption);