diff --git a/src/main/java/redis/clients/jedis/JedisPool.java b/src/main/java/redis/clients/jedis/JedisPool.java index b996217..1e0ead6 100644 --- a/src/main/java/redis/clients/jedis/JedisPool.java +++ b/src/main/java/redis/clients/jedis/JedisPool.java @@ -103,6 +103,16 @@ public class JedisPool extends Pool { return jedis; } + + @Override + public void activateObject(Object obj) throws Exception { + if (obj instanceof Jedis) { + final Jedis jedis = (Jedis)obj; + if (jedis.getDB() != database) { + jedis.select(database); + } + } + } public void destroyObject(final Object obj) throws Exception { if (obj instanceof Jedis) {