@ -15,6 +15,7 @@
*/
package org.redisson.api;
import java.util.List;
import java.util.Queue;
/**
@ -28,6 +29,9 @@ public interface RQueue<V> extends Queue<V>, RExpirable, RQueueAsync<V> {
V pollLastAndOfferFirstTo(String dequeName);
@Deprecated
V pollLastAndOfferFirstTo(RQueue<V> deque);
List<V> readAll();
}
@ -15,6 +15,8 @@
* {@link java.util.Queue} backed by Redis
*
@ -32,4 +34,6 @@ public interface RQueueAsync<V> extends RCollectionAsync<V> {
RFuture<V> pollLastAndOfferFirstToAsync(String queueName);
RFuture<List<V>> readAllAsync();