Add logging

Add logging #2021
AxonFramework · Nov 26, 2021 · ab8e5f1 · ab8e5f1
1 parent 71ef1e5
commit ab8e5f1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/messaging/src/main/java/org/axonframework/messaging/deadletter/InMemoryDeadLetterQueue.java b/messaging/src/main/java/org/axonframework/messaging/deadletter/InMemoryDeadLetterQueue.java
@@ -17,7 +17,10 @@
 package org.axonframework.messaging.deadletter;
 
 import org.axonframework.messaging.Message;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+import java.lang.invoke.MethodHandles;
 import java.util.PriorityQueue;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentNavigableMap;
@@ -33,17 +36,21 @@
  */
 public class InMemoryDeadLetterQueue<T extends Message<?>> implements DeadLetterQueue<T> {
 
+    private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
+
     private final ConcurrentNavigableMap<String, Queue<DeadLetter<T>>> deadLetters = new ConcurrentSkipListMap<>();
 
     @Override
     public void add(DeadLetter<T> deadLetter) {
+        logger.debug("Adding dead letter [{}].", deadLetter);
         deadLetters.computeIfAbsent(deadLetter.sequenceIdentifier(),
                                     sequenceId -> new PriorityQueue<>(DeadLetter::compare))
                    .add(deadLetter);
     }
 
     @Override
     public boolean contains(String sequenceIdentifier) {
+        logger.debug("Validating existence of sequence identifier [{}].", sequenceIdentifier);
         return deadLetters.containsKey(sequenceIdentifier);
     }