diff --git a/redisson/src/main/java/org/redisson/RedissonPriorityDeque.java b/redisson/src/main/java/org/redisson/RedissonPriorityDeque.java
index 8234a5bd4..eb4f9f9cc 100644
--- a/redisson/src/main/java/org/redisson/RedissonPriorityDeque.java
+++ b/redisson/src/main/java/org/redisson/RedissonPriorityDeque.java
@@ -142,7 +142,7 @@ public class RedissonPriorityDeque<V> extends RedissonPriorityQueue<V> implement
     }
 
     public RFuture<V> pollLastAsync() {
-        long threadId = Thread.currentThread().getId();
+        final long threadId = Thread.currentThread().getId();
         final RPromise<V> result = new RedissonPromise<V>();
         lock.lockAsync(threadId).addListener(new FutureListener<Void>() {
             @Override
diff --git a/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java b/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java
index d073ee5b3..14f3a17c8 100644
--- a/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java
+++ b/redisson/src/main/java/org/redisson/RedissonPriorityQueue.java
@@ -303,7 +303,7 @@ public class RedissonPriorityQueue<V> extends RedissonList<V> implements RPriori
 
 //    @Override
     public RFuture<V> pollAsync() {
-        long threadId = Thread.currentThread().getId();
+        final long threadId = Thread.currentThread().getId();
         final RPromise<V> result = new RedissonPromise<V>();
         lock.lockAsync(threadId).addListener(new FutureListener<Void>() {
             @Override