diff --git a/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java b/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
index 55d02cc22..aae353937 100644
--- a/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
+++ b/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
@@ -198,15 +198,16 @@ public class RedisQueuedBatchExecutor<V, R> extends BaseRedisBatchExecutor<V, R>
 
         
         if (entry.getConnectionFuture() != null) {
-            return entry.getConnectionFuture();
+            connectionFuture = entry.getConnectionFuture();
+            return connectionFuture;
         }
         
         synchronized (this) {
             if (entry.getConnectionFuture() != null) {
-                return entry.getConnectionFuture();
+                connectionFuture = entry.getConnectionFuture();
+                return connectionFuture;
             }
 
-            CompletableFuture<RedisConnection> connectionFuture;
             if (this.options.getExecutionMode() == ExecutionMode.REDIS_WRITE_ATOMIC) {
                 connectionFuture = connectionManager.connectionWriteOp(source, null);
             } else {