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 aacf402..8f12f48 100644 --- a/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java +++ b/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java @@ -205,7 +205,7 @@ public class ListCommandsTest extends JedisCommandTestBase { @Test public void blpop() { - List result = jedis.blpop(2, "foo"); + List result = jedis.blpop(1, "foo"); assertNull(result); new Thread(new Runnable() { @@ -213,21 +213,24 @@ public class ListCommandsTest extends JedisCommandTestBase { try { Jedis j = new Jedis("localhost"); j.connect(); + j.auth("foobared"); + j.flushAll(); List result = j.blpop(0, "foo"); assertNotNull(result); - assertEquals(1, result.size()); - assertEquals("bar", result.get(0)); + assertEquals(2, result.size()); + assertEquals("foo", result.get(0)); + assertEquals("bar", result.get(1)); } catch (Exception ex) { fail(ex.getMessage()); } } - }); + }).start(); jedis.lpush("foo", "bar"); } @Test public void brpop() { - List result = jedis.brpop(2, "foo"); + List result = jedis.brpop(1, "foo"); assertNull(result); new Thread(new Runnable() { @@ -235,15 +238,18 @@ public class ListCommandsTest extends JedisCommandTestBase { try { Jedis j = new Jedis("localhost"); j.connect(); + j.auth("foobared"); + j.flushAll(); List result = j.brpop(0, "foo"); assertNotNull(result); - assertEquals(1, result.size()); - assertEquals("bar", result.get(0)); + assertEquals(2, result.size()); + assertEquals("foo", result.get(0)); + assertEquals("bar", result.get(1)); } catch (Exception ex) { fail(ex.getMessage()); } } - }); + }).start(); jedis.lpush("foo", "bar"); } } \ No newline at end of file