From 906636d1b6354512750492edeb6424c74196743b Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Tue, 5 Oct 2021 14:22:59 +0300
Subject: [PATCH] Fixed - RPriorityQueue.add() method uses async method. #3864

---
 .../src/main/java/org/redisson/RedissonPriorityQueue.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java b/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java
index 5f80c2e43..3c7a4838f 100644
--- a/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java
+++ b/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java
@@ -161,7 +161,7 @@ public class RedissonPriorityQueue<V> extends RedissonList<V> implements RPriori
                 index = res.getIndex() + 1;
             }
                 
-            commandExecutor.evalWriteAsync(getRawName(), codec, RedisCommands.EVAL_VOID,
+            get(commandExecutor.evalWriteAsync(getRawName(), codec, RedisCommands.EVAL_VOID,
                "local len = redis.call('llen', KEYS[1]);"
                 + "if tonumber(ARGV[1]) < len then "
                     + "local pivot = redis.call('lindex', KEYS[1], ARGV[1]);"
@@ -169,8 +169,8 @@ public class RedissonPriorityQueue<V> extends RedissonList<V> implements RPriori
                     + "return;"
                 + "end;"
                 + "redis.call('rpush', KEYS[1], ARGV[2]);", 
-                    Arrays.<Object>asList(getRawName()),
-                    index, encode(value));
+                    Arrays.asList(getRawName()),
+                    index, encode(value)));
             return true;
         } finally {
             lock.unlock();