Debug logs for failed messages

Resolves spring-projects#416
sobychacko · Jun 23, 2023 · 6e79c12 · 6e79c12
1 parent 4178f71
commit 6e79c12
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java b/.../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);
 				}