diff --git a/src/main/java/org/redisson/command/CommandAsyncService.java b/src/main/java/org/redisson/command/CommandAsyncService.java index d5b38a246..cc1259964 100644 --- 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 void releaseConnection(NodeSource source, AsyncDetails details, RedisConnection connection) { - if (details.getAttemptPromise().isCancelled()) { + if (!details.getConnectionFuture().isSuccess()) { return; }