Skip to content

Commit 2747721

Browse files
committed
Fix exception filter on DLQ
1 parent dec907c commit 2747721

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/DotPulsar.Extensions.Resiliency/Extensions/DeadLetterFailureHandler.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public DeadLetterFailureHandler(
4141
}
4242

4343
public ValueTask HandleAsync(IMessage message, Exception exception, CancellationToken cancellationToken) {
44-
var preventRetry = retryExceptionHandler == null || retryExceptionHandler(message, exception);
44+
var preventRetry = retryExceptionHandler == null || !retryExceptionHandler(message, exception);
4545
var properties = exceptionSerializer(exception);
4646
return deadLetterPolicy.ReconsumeLater(message, delayTime: delayTimeSelector?.Invoke(message, exception), customProperties: properties, preventRetry: preventRetry, cancellationToken: cancellationToken);
4747
}

0 commit comments

Comments
 (0)