Skip to content

Commit b88f7f5

Browse files
committed
was logging the wrong exception
1 parent 9b5adbe commit b88f7f5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/client/impl/recovery/DefaultRetryHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ protected RetryResult doRetry(BiPredicate<RecordedEntity, Exception> condition,
107107
Exception exception = context.exception();
108108
while (attempts < retryAttempts) {
109109
if (condition.test(entity, exception)) {
110-
log(entity, context.exception(), attempts);
110+
log(entity, exception, attempts);
111111
backoffPolicy.backoff(attempts + 1);
112112
try {
113113
Object result = operation.call(context);

0 commit comments

Comments
 (0)