@ -26,7 +26,6 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import org.redisson.CommandBatchExecutorService.CommandEntry;
import org.redisson.client.RedisAskException;
import org.redisson.client.RedisClient;
import org.redisson.client.RedisConnection;
@ -127,7 +127,7 @@ abstract class BaseLoadBalancer implements LoadBalancer {
if (entry != null) {
return entries.get(entry);
}
RedisConnectionException exception = new RedisConnectionException("Can't find entry for " + client);
RedisConnectionException exception = new RedisConnectionException("Can't find entry for " + client.getAddr());
return connectionManager.getGroup().next().newFailedFuture(exception);
@ -102,7 +102,7 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager {
break;
} catch (RedisConnectionException e) {
// skip
log.warn("can't connect to sentinel", e);
} finally {
client.shutdownAsync();
@ -85,7 +85,7 @@ public class ConnectionPool<T extends RedisConnection> {
return promise;
RedisConnectionException exception = new RedisConnectionException("Can't aquire connection for " + entry.getClient());
RedisConnectionException exception = new RedisConnectionException("Can't aquire connection to " + entry.getClient().getAddr());
return executor.newFailedFuture(exception);