Add concurrency notice

Add concurrency notice #2021
AxonFramework · Aug 31, 2022 · 29510d1 · 29510d1
1 parent 76177f4
commit 29510d1
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/messaging/src/main/java/org/axonframework/messaging/deadletter/SequencedDeadLetterQueue.java b/messaging/src/main/java/org/axonframework/messaging/deadletter/SequencedDeadLetterQueue.java
@@ -152,6 +152,9 @@ void requeue(@Nonnull DeadLetter<? extends M> letter,
     /**
      * Returns the number of dead-letters for the sequence matching the given {@code sequenceIdentifier} contained in
      * this queue.
+     * <p>
+     * Note that there's a window of opportunity where the size might exceed the {@link #maxSequenceSize()} value to
+     * accompany concurrent usage.
      *
      * @param sequenceIdentifier The identifier of the sequence to retrieve the size from.
      * @return The number of dead-letters for the sequence matching the given {@code sequenceIdentifier}.
@@ -160,6 +163,9 @@ void requeue(@Nonnull DeadLetter<? extends M> letter,
 
     /**
      * Returns the number of unique sequences contained in this queue.
+     * <p>
+     * Note that there's a window of opportunity where the size might exceed the {@link #maxSequences()} value to
+     * accompany concurrent usage of this dead letter queue.
      *
      * @return The number of unique sequences contained in this queue.
      */