diff --git a/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java b/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java index 8f12f48..44bf6f9 100644 --- a/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java +++ b/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java @@ -204,52 +204,51 @@ public class ListCommandsTest extends JedisCommandTestBase { } @Test - public void blpop() { + public void blpop() throws InterruptedException { List result = jedis.blpop(1, "foo"); assertNull(result); new Thread(new Runnable() { public void run() { try { - Jedis j = new Jedis("localhost"); - j.connect(); - j.auth("foobared"); - j.flushAll(); - List result = j.blpop(0, "foo"); - assertNotNull(result); - assertEquals(2, result.size()); - assertEquals("foo", result.get(0)); - assertEquals("bar", result.get(1)); + Jedis j = createJedis(); + j.lpush("foo", "bar"); + j.disconnect(); } catch (Exception ex) { fail(ex.getMessage()); } } }).start(); - jedis.lpush("foo", "bar"); + + result = jedis.blpop(1, "foo"); + assertNotNull(result); + assertEquals(2, result.size()); + assertEquals("foo", result.get(0)); + assertEquals("bar", result.get(1)); } @Test - public void brpop() { + public void brpop() throws InterruptedException { List result = jedis.brpop(1, "foo"); assertNull(result); new Thread(new Runnable() { public void run() { try { - Jedis j = new Jedis("localhost"); - j.connect(); - j.auth("foobared"); - j.flushAll(); - List result = j.brpop(0, "foo"); - assertNotNull(result); - assertEquals(2, result.size()); - assertEquals("foo", result.get(0)); - assertEquals("bar", result.get(1)); + Jedis j = createJedis(); + j.lpush("foo", "bar"); + j.disconnect(); } catch (Exception ex) { fail(ex.getMessage()); } } }).start(); - jedis.lpush("foo", "bar"); + + result = jedis.brpop(1, "foo"); + assertNotNull(result); + assertEquals(2, result.size()); + assertEquals("foo", result.get(0)); + assertEquals("bar", result.get(1)); + } } \ No newline at end of file