diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index 42c647ba1..ff04c5606 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -697,7 +697,7 @@ public class CommandAsyncService implements CommandAsyncExecutor { if (details.getConnectionFuture().cancel(false)) { if (details.getException() == null) { - details.setException(new RedisTimeoutException("Unable to get connection! Try to increase 'nettyThreads' and 'connection pool' settings or set decodeInExecutor = true and increase 'threads' setting" + details.setException(new RedisTimeoutException("Unable to get connection! Try to increase 'nettyThreads' and/or connection pool size settings" + "Node source: " + source + ", command: " + LogHelper.toString(command, details.getParams()) + " after " + details.getAttempt() + " retry attempts")); @@ -708,7 +708,7 @@ public class CommandAsyncService implements CommandAsyncExecutor { if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) { if (details.getWriteFuture() != null && details.getWriteFuture().cancel(false)) { if (details.getException() == null) { - details.setException(new RedisTimeoutException("Unable to send command! " + details.setException(new RedisTimeoutException("Unable to send command! Try to increase 'nettyThreads' and/or connection pool size settings " + "Node source: " + source + ", connection: " + details.getConnectionFuture().getNow() + ", current command in queue: " + details.getConnectionFuture().getNow().getCurrentCommand() + ", command: " + LogHelper.toString(command, details.getParams()) @@ -740,7 +740,7 @@ public class CommandAsyncService implements CommandAsyncExecutor { if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) { if (details.getException() == null) { - details.setException(new RedisTimeoutException("Unable to send command! Node source: " + source + details.setException(new RedisTimeoutException("Unable to send command! Try to increase 'nettyThreads' and/or connection pool size settings. Node source: " + source + ", command: " + LogHelper.toString(command, details.getParams()) + " after " + connectionManager.getConfig().getRetryAttempts() + " retry attempts")); }