merge - jedis pull request #429

2013-06-29 12:59:32 +08:00
parent f1db0b9cac
commit 7b6006b669
1 changed files with 10 additions and 0 deletions
--- 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<Jedis> {
            
            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) {