diff --git a/src/main/java/redis/clients/jedis/Connection.java b/src/main/java/redis/clients/jedis/Connection.java index f9fe559482..9325de80d7 100644 --- a/src/main/java/redis/clients/jedis/Connection.java +++ b/src/main/java/redis/clients/jedis/Connection.java @@ -343,7 +343,7 @@ protected void flush() { protected Object readProtocolWithCheckingBroken() { if (broken) { - throw new JedisConnectionException("Attempting to read from a broken connection"); + throw new JedisConnectionException("Attempting to read from a broken connection."); } try { diff --git a/src/main/java/redis/clients/jedis/DefaultJedisSocketFactory.java b/src/main/java/redis/clients/jedis/DefaultJedisSocketFactory.java index a2d963e221..c9ef6646ba 100644 --- a/src/main/java/redis/clients/jedis/DefaultJedisSocketFactory.java +++ b/src/main/java/redis/clients/jedis/DefaultJedisSocketFactory.java @@ -60,7 +60,7 @@ private Socket connectToFirstSuccessfulHost(HostAndPort hostAndPort) throws Exce Collections.shuffle(hosts); } - JedisConnectionException jce = new JedisConnectionException("Failed to connect to any host resolved for DNS name."); + JedisConnectionException jce = new JedisConnectionException("Failed to connect to " + hostAndPort + "."); for (InetAddress host : hosts) { try { Socket socket = new Socket(); diff --git a/src/main/java/redis/clients/jedis/providers/MultiClusterPooledConnectionProvider.java b/src/main/java/redis/clients/jedis/providers/MultiClusterPooledConnectionProvider.java index 9ddf8e810a..eb443bca1e 100644 --- a/src/main/java/redis/clients/jedis/providers/MultiClusterPooledConnectionProvider.java +++ b/src/main/java/redis/clients/jedis/providers/MultiClusterPooledConnectionProvider.java @@ -178,7 +178,7 @@ public int incrementActiveMultiClusterIndex() { throw new JedisConnectionException("Cluster/database endpoint could not failover since the MultiClusterClientConfig was not " + "provided with an additional cluster/database endpoint according to its prioritized sequence. " + - "If applicable, consider failing back OR restarting with an available cluster/database endpoint"); + "If applicable, consider failing back OR restarting with an available cluster/database endpoint."); } else activeMultiClusterIndex++;