diff --git a/src/test/java/redis/clients/jedis/tests/JedisSentinelPoolTest.java b/src/test/java/redis/clients/jedis/tests/JedisSentinelPoolTest.java index c8df9c5..c88bd55 100644 --- a/src/test/java/redis/clients/jedis/tests/JedisSentinelPoolTest.java +++ b/src/test/java/redis/clients/jedis/tests/JedisSentinelPoolTest.java @@ -34,6 +34,22 @@ public class JedisSentinelPoolTest extends JedisTestBase { sentinelJedis1 = new Jedis(sentinel1.getHost(), sentinel1.getPort()); } + + @Test + public void checkCloseableConnections() throws Exception { + GenericObjectPoolConfig config = new GenericObjectPoolConfig(); + + Closer closer = new Closer(); + JedisSentinelPool pool = closer.register(new JedisSentinelPool( + MASTER_NAME, sentinels, config, 1000, "foobared", 2)); + Jedis jedis = pool.getResource(); + jedis.auth("foobared"); + jedis.set("foo", "bar"); + assertEquals("bar", jedis.get("foo")); + pool.returnResource(jedis); + closer.close(); + assertTrue(pool.isClosed()); + } @Test public void ensureSafeTwiceFailover() throws InterruptedException { diff --git a/src/test/java/redis/clients/jedis/tests/ShardedJedisPoolTest.java b/src/test/java/redis/clients/jedis/tests/ShardedJedisPoolTest.java index ee7951b..272656c 100644 --- a/src/test/java/redis/clients/jedis/tests/ShardedJedisPoolTest.java +++ b/src/test/java/redis/clients/jedis/tests/ShardedJedisPoolTest.java @@ -54,6 +54,19 @@ public class ShardedJedisPoolTest extends Assert { pool.destroy(); } + @Test + public void checkCloseableConnections() throws Exception { + Closer closer = new Closer(); + ShardedJedisPool pool = closer.register(new ShardedJedisPool( + new GenericObjectPoolConfig(), shards)); + ShardedJedis jedis = pool.getResource(); + jedis.set("foo", "bar"); + assertEquals("bar", jedis.get("foo")); + pool.returnResource(jedis); + closer.close(); + assertTrue(pool.isClosed()); + } + @Test public void checkConnectionWithDefaultPort() { ShardedJedisPool pool = new ShardedJedisPool(