refactoring

pull/2122/head
Nikita Koksharov 6 years ago
parent ed473d8db7
commit 09c83745ad

@ -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() + "]";
}
}

@ -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"));
}

Loading…
Cancel
Save