Debug logs for failed messages

sobychacko · sobychacko · commit 6e79c12aa1d5 · 2023-06-23T14:18:45.000-04:00
Resolves #416
diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java
@@ -493,6 +493,8 @@ else if (this.listener != null) {
 				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);
 				}

Original file line number	Diff line number	Diff line change
`@@ -493,6 +493,8 @@ else if (this.listener != null) {`
`493`	`493`	`inRetryMode.compareAndSet(true, false);`
`494`	`494`	`}`
`495`	`495`	`catch (Exception e) {`
	`496`	`+ DefaultPulsarMessageListenerContainer.this.logger.debug(e,`
	`497`	`+ () -> "Error dispatching the message to the listener.");`
`496`	`498`	`if (this.pulsarConsumerErrorHandler != null) {`
`497`	`499`	`invokeRecordListenerErrorHandler(inRetryMode, message, e);`
`498`	`500`	`}`