From 8eed10c39dfb50297d75b463fb1039699dd2c564 Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 1 Dec 2015 12:26:45 +0300 Subject: [PATCH] few comments fixed --- src/main/java/org/redisson/core/RBlockingQueue.java | 2 +- src/main/java/org/redisson/core/RBlockingQueueAsync.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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. *