From 731d368785f3bb5aa327cae4d5e835574fff9996 Mon Sep 17 00:00:00 2001 From: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com> Date: Tue, 16 Jul 2024 19:36:56 +0600 Subject: [PATCH] JedisConnectionException contains HostAndPort from DefaultJedisSocketFactory --- src/main/java/redis/clients/jedis/Connection.java | 2 +- .../java/redis/clients/jedis/DefaultJedisSocketFactory.java | 2 +- .../jedis/providers/MultiClusterPooledConnectionProvider.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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++;