diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java index 5d4c625..3f6c057 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedis.java +++ b/src/main/java/redis/clients/jedis/ShardedJedis.java @@ -125,12 +125,18 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands, Jedis j = getShard(arg); return j.blpop(arg); } - + public List blpop(int timeout,String key){ + Jedis j = getShard(key); + return j.blpop(timeout,key); + } public List brpop(String arg) { Jedis j = getShard(arg); return j.brpop(arg); } - + public List brpop(int timeout,String key) { + Jedis j = getShard(key); + return j.brpop(timeout,key); + } public Long decrBy(String key, long integer) { Jedis j = getShard(key); return j.decrBy(key, integer);