Fixed bug in blpop and brpop tests
This commit is contained in:
@@ -205,7 +205,7 @@ public class ListCommandsTest extends JedisCommandTestBase {
|
||||
|
||||
@Test
|
||||
public void blpop() {
|
||||
List<String> result = jedis.blpop(2, "foo");
|
||||
List<String> 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<String> 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<String> result = jedis.brpop(2, "foo");
|
||||
List<String> 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<String> 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");
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user