Update src/main/java/redis/clients/jedis/JedisClusterCommand.java

Co-authored-by: Mina Asham <mina.asham@hotmail.com>
redis · Feb 17, 2021 · 4f80d73 · 4f80d73
1 parent 4f138e4
commit 4f80d73
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/redis/clients/jedis/JedisClusterCommand.java b/src/main/java/redis/clients/jedis/JedisClusterCommand.java
@@ -86,6 +86,7 @@ private T runWithRetries(final int slot) {
     // If we got one redirection, stick with that and don't try anything else
     Supplier<Jedis> redirectionSupplier = null;
 
+    Exception lastException = null;
     for (int currentAttempt = 0; currentAttempt < this.maxAttempts; currentAttempt++) {
       Jedis connection = null;
       try {
@@ -98,15 +99,17 @@ private T runWithRetries(final int slot) {
       } catch (JedisNoReachableClusterNodeException e) {
         throw e;
       } catch (JedisConnectionException e) {
+        lastException = e;
         connectionSupplier = handleConnectionProblem(slot, currentAttempt);
       } catch (JedisRedirectionException e) {
+        lastException = e;
         redirectionSupplier = handleRedirection(connection, e);
       } finally {
         releaseConnection(connection);
       }
     }
 
-    throw new JedisClusterMaxAttemptsException("No more cluster attempts left.");
+    throw new JedisClusterMaxAttemptsException("No more cluster attempts left.", lastException);
   }
 
   private Supplier<Jedis> handleConnectionProblem(final int slot, int currentAttempt) {