was logging the wrong exception

rabbitmq · Aug 28, 2018 · b88f7f5 · b88f7f5
1 parent 9b5adbe
commit b88f7f5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java b/src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java
@@ -107,7 +107,7 @@ protected RetryResult doRetry(BiPredicate<RecordedEntity, Exception> condition,
         Exception exception = context.exception();
         while (attempts < retryAttempts) {
             if (condition.test(entity, exception)) {
-                log(entity, context.exception(), attempts);
+                log(entity, exception, attempts);
                 backoffPolicy.backoff(attempts + 1);
                 try {
                     Object result = operation.call(context);