log error if attemptPromise couldn't be set as failed

pull/1321/head
Nikita 7 years ago
parent 6803dd29cb
commit bfe853989c

@ -672,7 +672,9 @@ public class CommandAsyncService implements CommandAsyncExecutor {
"Unable to send command! Node source: " + details.getSource() + ", connection: " + future.channel() + "Unable to send command! Node source: " + details.getSource() + ", connection: " + future.channel() +
", command: " + details.getCommand() + ", params: " + LogHelper.toString(details.getParams()), future.cause())); ", command: " + details.getCommand() + ", params: " + LogHelper.toString(details.getParams()), future.cause()));
if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) { if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) {
details.getAttemptPromise().tryFailure(details.getException()); if (!details.getAttemptPromise().tryFailure(details.getException())) {
log.error(details.getException().getMessage());
}
} }
return; return;
} }

Loading…
Cancel
Save