diff --git a/src/main/java/org/redisson/CommandExecutorService.java b/src/main/java/org/redisson/CommandExecutorService.java index dbd783840..fb448e92c 100644 --- a/src/main/java/org/redisson/CommandExecutorService.java +++ b/src/main/java/org/redisson/CommandExecutorService.java @@ -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; diff --git a/src/main/java/org/redisson/connection/BaseLoadBalancer.java b/src/main/java/org/redisson/connection/BaseLoadBalancer.java index 9963842c9..0ba8c5782 100644 --- a/src/main/java/org/redisson/connection/BaseLoadBalancer.java +++ b/src/main/java/org/redisson/connection/BaseLoadBalancer.java @@ -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); } diff --git a/src/main/java/org/redisson/connection/SentinelConnectionManager.java b/src/main/java/org/redisson/connection/SentinelConnectionManager.java index 74dddf378..209bf6397 100755 --- a/src/main/java/org/redisson/connection/SentinelConnectionManager.java +++ b/src/main/java/org/redisson/connection/SentinelConnectionManager.java @@ -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(); } diff --git a/src/main/java/org/redisson/misc/ConnectionPool.java b/src/main/java/org/redisson/misc/ConnectionPool.java index 568e0c283..03ff74392 100644 --- a/src/main/java/org/redisson/misc/ConnectionPool.java +++ b/src/main/java/org/redisson/misc/ConnectionPool.java @@ -85,7 +85,7 @@ public class ConnectionPool { 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); }