Skip to content

Commit 4d00e37

Browse files
committed
Validate pooled Redis connections before publish
1 parent d7d3a5d commit 4d00e37

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

‎SimpleAPI/src/main/java/com/bencodez/simpleapi/servercomm/redis/RedisHandler.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import redis.clients.jedis.Jedis;
1818
import redis.clients.jedis.JedisClientConfig;
1919
import redis.clients.jedis.JedisPool;
20+
import redis.clients.jedis.JedisPoolConfig;
2021

2122
public abstract class RedisHandler {
2223

@@ -52,7 +53,9 @@ public RedisHandler(String host, int port, String username, String password, int
5253
}
5354

5455
this.clientConfig = cfg.build();
55-
this.publisherPool = new JedisPool(endpoint, clientConfig);
56+
JedisPoolConfig publisherPoolConfig = new JedisPoolConfig();
57+
publisherPoolConfig.setTestOnBorrow(true);
58+
this.publisherPool = new JedisPool(publisherPoolConfig, endpoint, clientConfig);
5659
this.publisherExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS,
5760
new ArrayBlockingQueue<>(PUBLISH_QUEUE_CAPACITY), runnable -> {
5861
Thread thread = new Thread(runnable, "RedisPublishThread-" + endpoint);

0 commit comments

Comments
 (0)