From da3092e6952d13d2e8c10ba028979a1da78fe591 Mon Sep 17 00:00:00 2001 From: Dmytro Date: Fri, 25 Mar 2011 14:35:29 +0000 Subject: [PATCH] reverted back vetify() as connection checks could be disabled in pool config --- .../java/redis/clients/jedis/ShardedJedisPool.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPool.java b/src/main/java/redis/clients/jedis/ShardedJedisPool.java index d314e00..62d0cd1 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedisPool.java +++ b/src/main/java/redis/clients/jedis/ShardedJedisPool.java @@ -61,7 +61,17 @@ public class ShardedJedisPool extends Pool { } public boolean validateObject(final Object obj) { - return true; + try { + ShardedJedis jedis = (ShardedJedis) obj; + for (Jedis shard : jedis.getAllShards()) { + if (!shard.isConnected() || !shard.ping().equals("PONG")) { + return false; + } + } + return true; + } catch (Exception ex) { + return false; + } } } } \ No newline at end of file