Add ability to pass ClusterConnectionProvider to JedisCluster (#3169)

redis · Oct 20, 2022 · 448207b · 448207b
1 parent e166fb5
commit 448207b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/main/java/redis/clients/jedis/JedisCluster.java b/src/main/java/redis/clients/jedis/JedisCluster.java
@@ -6,6 +6,7 @@
 import java.util.Set;
 import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
 import redis.clients.jedis.executors.ClusterCommandExecutor;
+import redis.clients.jedis.providers.ClusterConnectionProvider;
 
 public class JedisCluster extends UnifiedJedis {
 
@@ -184,6 +185,11 @@ public JedisCluster(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfi
     super(clusterNodes, clientConfig, maxAttempts, maxTotalRetriesDuration);
   }
 
+  public JedisCluster(ClusterConnectionProvider provider, int maxAttempts,
+      Duration maxTotalRetriesDuration) {
+    super(provider, maxAttempts, maxTotalRetriesDuration);
+  }
+
   public Map<String, ConnectionPool> getClusterNodes() {
     return ((ClusterCommandExecutor) executor).provider.getNodes();
   }