From 278b6d7ea17a12b49e67051fdf552e9886e6a8c8 Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 6 Jun 2017 10:34:07 +0300 Subject: [PATCH] fixed RedissonBoundedBlockingQueue.pollAsync blocks if timeout is less than 1 second #896 --- .../main/java/org/redisson/RedissonBoundedBlockingQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/RedissonBoundedBlockingQueue.java b/redisson/src/main/java/org/redisson/RedissonBoundedBlockingQueue.java index ac309c5a9..1a0186270 100644 --- a/redisson/src/main/java/org/redisson/RedissonBoundedBlockingQueue.java +++ b/redisson/src/main/java/org/redisson/RedissonBoundedBlockingQueue.java @@ -216,7 +216,7 @@ public class RedissonBoundedBlockingQueue extends RedissonQueue implements @Override public RFuture pollAsync(long timeout, TimeUnit unit) { - RFuture takeFuture = commandExecutor.writeAsync(getName(), codec, RedisCommands.BLPOP_VALUE, getName(), unit.toSeconds(timeout)); + RFuture takeFuture = commandExecutor.writeAsync(getName(), codec, RedisCommands.BLPOP_VALUE, getName(), toSeconds(timeout, unit)); return wrapTakeFuture(takeFuture); }