diff --git a/redisson/src/main/java/org/redisson/client/RedisConnection.java b/redisson/src/main/java/org/redisson/client/RedisConnection.java index c6666a3b2..08eb94440 100644 --- a/redisson/src/main/java/org/redisson/client/RedisConnection.java +++ b/redisson/src/main/java/org/redisson/client/RedisConnection.java @@ -289,8 +289,7 @@ public class RedisConnection implements RedisCommands { @Override public String toString() { - QueueCommand command = channel.attr(CommandsQueue.CURRENT_COMMAND).get(); - return getClass().getSimpleName() + "@" + System.identityHashCode(this) + " [redisClient=" + redisClient + ", channel=" + channel + ", command=" + command + "]"; + return getClass().getSimpleName() + "@" + System.identityHashCode(this) + " [redisClient=" + redisClient + ", channel=" + channel + ", currentCommand=" + getCurrentCommand() + "]"; } } diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index ff04c5606..5ca5dff03 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -710,7 +710,6 @@ public class CommandAsyncService implements CommandAsyncExecutor { if (details.getException() == null) { 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()) + " after " + connectionManager.getConfig().getRetryAttempts() + " retry attempts")); }