Skip to content

Commit beb5e14

Browse files
authored
[automatic failover] Configure max total connections for EchoStrategy (#4268)
- set maxtotal connections for echoStrategy
1 parent aaed216 commit beb5e14

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/main/java/redis/clients/jedis/mcf/EchoStrategy.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,14 @@
11
package redis.clients.jedis.mcf;
22

3+
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
34
import org.slf4j.Logger;
45
import org.slf4j.LoggerFactory;
6+
7+
import redis.clients.jedis.Connection;
58
import redis.clients.jedis.Endpoint;
69
import redis.clients.jedis.HostAndPort;
710
import redis.clients.jedis.JedisClientConfig;
11+
import redis.clients.jedis.JedisPooled;
812
import redis.clients.jedis.UnifiedJedis;
913
import redis.clients.jedis.MultiClusterClientConfig.StrategySupplier;
1014

@@ -20,7 +24,9 @@ public EchoStrategy(HostAndPort hostAndPort, JedisClientConfig jedisClientConfig
2024

2125
public EchoStrategy(HostAndPort hostAndPort, JedisClientConfig jedisClientConfig,
2226
HealthCheckStrategy.Config config) {
23-
this.jedis = new UnifiedJedis(hostAndPort, jedisClientConfig);
27+
GenericObjectPoolConfig<Connection> poolConfig = new GenericObjectPoolConfig<>();
28+
poolConfig.setMaxTotal(2);
29+
this.jedis = new JedisPooled(hostAndPort, jedisClientConfig, poolConfig);
2430
this.config = config;
2531
}
2632

0 commit comments

Comments
 (0)