diff --git a/redisson/src/main/java/org/redisson/api/RQueue.java b/redisson/src/main/java/org/redisson/api/RQueue.java index b63f367d4..380038023 100644 --- a/redisson/src/main/java/org/redisson/api/RQueue.java +++ b/redisson/src/main/java/org/redisson/api/RQueue.java @@ -15,6 +15,7 @@ */ package org.redisson.api; +import java.util.List; import java.util.Queue; /** @@ -28,6 +29,9 @@ public interface RQueue extends Queue, RExpirable, RQueueAsync { V pollLastAndOfferFirstTo(String dequeName); + @Deprecated V pollLastAndOfferFirstTo(RQueue deque); + List readAll(); + } diff --git a/redisson/src/main/java/org/redisson/api/RQueueAsync.java b/redisson/src/main/java/org/redisson/api/RQueueAsync.java index 5e4290e32..5b953a77c 100644 --- a/redisson/src/main/java/org/redisson/api/RQueueAsync.java +++ b/redisson/src/main/java/org/redisson/api/RQueueAsync.java @@ -15,6 +15,8 @@ */ package org.redisson.api; +import java.util.List; + /** * {@link java.util.Queue} backed by Redis * @@ -32,4 +34,6 @@ public interface RQueueAsync extends RCollectionAsync { RFuture pollLastAndOfferFirstToAsync(String queueName); + RFuture> readAllAsync(); + }