Feature - RBlockingQueue.pollLastFromAnyWithName()

Signed-off-by: seakider <seakider@gmail.com>
pull/6426/head
seakider 2 weeks ago
parent 960c02386e
commit 02e7bece3c

@ -298,7 +298,7 @@ public interface RedisCommands {
RedisCommand<Object> BZPOPMIN_VALUE = new RedisCommand<Object>("BZPOPMIN", new ScoredSortedSetPolledObjectDecoder()); RedisCommand<Object> BZPOPMIN_VALUE = new RedisCommand<Object>("BZPOPMIN", new ScoredSortedSetPolledObjectDecoder());
RedisCommand<Object> BZPOPMAX_VALUE = new RedisCommand<Object>("BZPOPMAX", new ScoredSortedSetPolledObjectDecoder()); RedisCommand<Object> BZPOPMAX_VALUE = new RedisCommand<Object>("BZPOPMAX", new ScoredSortedSetPolledObjectDecoder());
RedisCommand<Map<String, List<Object>>> BLPOP_NAME = new RedisCommand<>("BLPOP", RedisCommand<org.redisson.api.Entry<String, Object>> BLPOP_NAME = new RedisCommand<>("BLPOP",
new ListObjectDecoder(0) { new ListObjectDecoder(0) {
@Override @Override
public Object decode(List parts, State state) { public Object decode(List parts, State state) {
@ -309,7 +309,7 @@ public interface RedisCommands {
} }
}); });
RedisCommand<Map<String, List<Object>>> BRPOP_NAME = new RedisCommand<>("BRPOP", RedisCommand<org.redisson.api.Entry<String, Object>> BRPOP_NAME = new RedisCommand<>("BRPOP",
new ListObjectDecoder(0) { new ListObjectDecoder(0) {
@Override @Override
public Object decode(List parts, State state) { public Object decode(List parts, State state) {

Loading…
Cancel
Save