diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index c4b07928b..7610f35b0 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -672,7 +672,9 @@ public class CommandAsyncService implements CommandAsyncExecutor { "Unable to send command! Node source: " + details.getSource() + ", connection: " + future.channel() + ", command: " + details.getCommand() + ", params: " + LogHelper.toString(details.getParams()), future.cause())); if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) { - details.getAttemptPromise().tryFailure(details.getException()); + if (!details.getAttemptPromise().tryFailure(details.getException())) { + log.error(details.getException().getMessage()); + } } return; }