Connection leak fixed. #338

9 years ago · 4c897806f6
parent b70dd92b6d
commit 4c897806f6
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/org/redisson/command/CommandAsyncService.java
+++ b/src/main/java/org/redisson/command/CommandAsyncService.java
@ -505,7 +505,7 @@ public class CommandAsyncService implements CommandAsyncExecutor {
    }

    private <V, R> void releaseConnection(NodeSource source, AsyncDetails<V, R> details, RedisConnection connection) {
-        if (details.getAttemptPromise().isCancelled()) {
+        if (!details.getConnectionFuture().isSuccess()) {
            return;
        }