From 02e7bece3c1141ce8405587e54f8ad957ed9b19d Mon Sep 17 00:00:00 2001 From: seakider Date: Mon, 10 Feb 2025 21:52:22 +0800 Subject: [PATCH] Feature - RBlockingQueue.pollLastFromAnyWithName() Signed-off-by: seakider --- .../main/java/org/redisson/client/protocol/RedisCommands.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java b/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java index 9d0a9d4ca..0e66d95b6 100644 --- a/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java +++ b/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java @@ -298,7 +298,7 @@ public interface RedisCommands { RedisCommand BZPOPMIN_VALUE = new RedisCommand("BZPOPMIN", new ScoredSortedSetPolledObjectDecoder()); RedisCommand BZPOPMAX_VALUE = new RedisCommand("BZPOPMAX", new ScoredSortedSetPolledObjectDecoder()); - RedisCommand>> BLPOP_NAME = new RedisCommand<>("BLPOP", + RedisCommand> BLPOP_NAME = new RedisCommand<>("BLPOP", new ListObjectDecoder(0) { @Override public Object decode(List parts, State state) { @@ -309,7 +309,7 @@ public interface RedisCommands { } }); - RedisCommand>> BRPOP_NAME = new RedisCommand<>("BRPOP", + RedisCommand> BRPOP_NAME = new RedisCommand<>("BRPOP", new ListObjectDecoder(0) { @Override public Object decode(List parts, State state) {