From 5018a3c31cc2dd10b7bb5d812f75f72548e233ec Mon Sep 17 00:00:00 2001 From: Nikita Date: Thu, 3 Sep 2015 14:25:51 +0300 Subject: [PATCH] BlockingQueue.peek race-condition fixed. #106 --- src/main/java/org/redisson/RedissonQueue.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main/java/org/redisson/RedissonQueue.java b/src/main/java/org/redisson/RedissonQueue.java index 8e6130c74..e5da5bdcd 100644 --- a/src/main/java/org/redisson/RedissonQueue.java +++ b/src/main/java/org/redisson/RedissonQueue.java @@ -88,10 +88,7 @@ public class RedissonQueue extends RedissonList implements RQueue { @Override public V peek() { - if (isEmpty()) { - return null; - } - return get(0); + return getValue(0); } @Override