diff --git a/src/main/java/org/redisson/core/RBlockingQueue.java b/src/main/java/org/redisson/core/RBlockingQueue.java index f7cf67862..e0ab5e344 100644 --- a/src/main/java/org/redisson/core/RBlockingQueue.java +++ b/src/main/java/org/redisson/core/RBlockingQueue.java @@ -27,7 +27,7 @@ import java.util.concurrent.TimeUnit; public interface RBlockingQueue extends BlockingQueue, RQueue, RBlockingQueueAsync { /** - * Retrieves and removes the head of this queue in async mode, waiting up to the + * Retrieves and removes first available head of any queue, waiting up to the * specified wait time if necessary for an element to become available * in any of defined queues including queue own. * diff --git a/src/main/java/org/redisson/core/RBlockingQueueAsync.java b/src/main/java/org/redisson/core/RBlockingQueueAsync.java index 279604a38..55de5a8e5 100644 --- a/src/main/java/org/redisson/core/RBlockingQueueAsync.java +++ b/src/main/java/org/redisson/core/RBlockingQueueAsync.java @@ -26,10 +26,10 @@ import io.netty.util.concurrent.Future; * @author Nikita Koksharov * @param the type of elements held in this collection */ -public interface RBlockingQueueAsync extends RQueueAsync, RExpirableAsync { +public interface RBlockingQueueAsync extends RQueueAsync { /** - * Retrieves and removes the head of this queue in async mode, waiting up to the + * Retrieves and removes first available head of any queue in async mode, waiting up to the * specified wait time if necessary for an element to become available * in any of defined queues including queue own. *