enhance the message rejected log with information to identify the mes…

…sage that was rejected Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Sep 8, 2021 · 44df6b0 · 44df6b0
1 parent 2e09be3
commit 44df6b0
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...va/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaAcknowledgableMessage.java b/...va/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaAcknowledgableMessage.java
@@ -20,6 +20,7 @@
 import org.eclipse.ditto.connectivity.api.ExternalMessage;
 import org.eclipse.ditto.connectivity.service.messaging.AcknowledgeableMessage;
 import org.eclipse.ditto.connectivity.service.messaging.monitoring.ConnectionMonitor;
+import org.eclipse.ditto.connectivity.service.messaging.monitoring.logs.InfoProviderFactory;
 
 import akka.kafka.ConsumerMessage;
 
@@ -49,10 +50,10 @@ final class KafkaAcknowledgableMessage {
                 },
                 shouldRedeliver -> {
                     if (shouldRedeliver) {
-                        ackMonitor.exception("Message was rejected and redelivery is requested.");
+                        ackMonitor.exception(message, "Message was rejected and redelivery is requested.");
                         acknowledgementFuture.completeExceptionally(MessageRejectedException.getInstance());
                     } else {
-                        ackMonitor.exception("Message was rejected and no redelivery is requested.");
+                        ackMonitor.exception(message, "Message was rejected and no redelivery is requested.");
                         acknowledgementFuture.complete(committableOffset);
                     }
                 });