Debug logs for failed messages

Resolves https://github.com/spring-projects/spring-pulsar/issues/416
This commit is contained in:
Soby Chacko
2023-06-23 14:18:04 -04:00
parent 12e557c79a
commit 9d3da36377

View File

@@ -493,6 +493,8 @@ public class DefaultPulsarMessageListenerContainer<T> extends AbstractPulsarMess
inRetryMode.compareAndSet(true, false);
}
catch (Exception e) {
DefaultPulsarMessageListenerContainer.this.logger.debug(e,
() -> "Error dispatching the message to the listener.");
if (this.pulsarConsumerErrorHandler != null) {
invokeRecordListenerErrorHandler(inRetryMode, message, e);
}