From b2eb5d6d1c1e15c32bb702bf60b638044f79e510 Mon Sep 17 00:00:00 2001 From: Roland von Herget Date: Fri, 28 Feb 2014 14:36:53 +0100 Subject: [PATCH] add a returnBrokenResource method, this way we can throw away broken ShardedJedis objects (e.g. due to timeouts on one shard) --- src/main/java/redis/clients/jedis/ShardedJedisPool.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPool.java b/src/main/java/redis/clients/jedis/ShardedJedisPool.java index dd56ac1..7816c1e 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedisPool.java +++ b/src/main/java/redis/clients/jedis/ShardedJedisPool.java @@ -32,6 +32,10 @@ public class ShardedJedisPool extends Pool { super(poolConfig, new ShardedJedisFactory(shards, algo, keyTagPattern)); } + public void returnBrokenResource(final ShardedJedis resource) { + returnBrokenResourceObject(resource); + } + /** * PoolableObjectFactory custom impl. */