Merge pull request #5883 from seakider/fix_connection_release

Fixed - releaseConnection may not execute correctly
9 months ago · 54a3a09b57
parent f0b08cbdfc df46410df4
commit 54a3a09b57
1 changed files with 1 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
+++ b/redisson/src/main/java/org/redisson/command/RedisQueuedBatchExecutor.java
@ -99,7 +99,7 @@ public class RedisQueuedBatchExecutor<V, R> extends BaseRedisBatchExecutor<V, R>
        if (RedisCommands.EXEC.getName().equals(command.getName())
                || RedisCommands.DISCARD.getName().equals(command.getName())) {
            if (attempt < attempts
-                    && attemptPromise.isCompletedExceptionally()) {
+                    && attemptPromise.isCancelled()) {
                return;
            }