refactoring

10 months ago · 28f94d2013
parent af3dd26989
commit 28f94d2013
1 changed files with 5 additions and 0 deletions
--- a/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
+++ b/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
@ -98,6 +98,11 @@ public class RedisQueuedBatchExecutor<V, R> extends BaseRedisBatchExecutor<V, R>
    protected void releaseConnection(CompletableFuture<R> attemptPromise, CompletableFuture<RedisConnection> connectionFuture) {
        if (RedisCommands.EXEC.getName().equals(command.getName())
                || RedisCommands.DISCARD.getName().equals(command.getName())) {
+            if (attempt < attempts
+                    && attemptPromise.isCompletedExceptionally()) {
+                return;
+            }
+
            super.releaseConnection(attemptPromise, connectionFuture);
        }
    }