diff --git a/src/main/java/redis/clients/jedis/JedisCluster.java b/src/main/java/redis/clients/jedis/JedisCluster.java index 769aa5070c..15fed0297e 100644 --- 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 clusterNodes, JedisClientConfig clientConfi super(clusterNodes, clientConfig, maxAttempts, maxTotalRetriesDuration); } + public JedisCluster(ClusterConnectionProvider provider, int maxAttempts, + Duration maxTotalRetriesDuration) { + super(provider, maxAttempts, maxTotalRetriesDuration); + } + public Map getClusterNodes() { return ((ClusterCommandExecutor) executor).provider.getNodes(); }