diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java b/src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java
index cef59de90f..59b6adacda 100644
--- a/src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java
+++ b/src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java
@@ -100,7 +100,7 @@ protected <T extends RecordedEntity> RetryResult doRetry(RetryCondition<T> condi
         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);