Class JpaSequencedDeadLetterQueue<M extends EventMessage<?>>
- Type Parameters:
M- An implementation ofMessagecontained in thedead-letterswithin this queue.
- All Implemented Interfaces:
SequencedDeadLetterQueue<M>
SequencedDeadLetterQueue, used for storing dead letters containing
Eventmessages durably as a DeadLetterEntry.
Keeps the insertion order intact by saving an incremented index within each unique sequence, backed by the
DeadLetterEntry.getSequenceIndex() property. Each sequence is uniquely identified by the sequence identifier,
stored in the DeadLetterEntry.getSequenceIdentifier() field.
When processing an item, single execution across all applications is guaranteed by setting the
DeadLetterEntry.getProcessingStarted() property, locking other processes out of the sequence for the
configured claimDuration (30 seconds by default).
The stored entries are converted to a JpaDeadLetter when they need to be processed or
filtered. In order to restore the original EventMessage a matching DeadLetterJpaConverter is used.
The default supports all EventMessage implementations provided by the framework. If you have a custom
variant, you have to build your own.
upcasters are not supported by this implementation, so
breaking changes for events messages stored in the queue should be avoided.
- Since:
- 4.6.0
- Author:
- Mitchell Herrijgers
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classJpaSequencedDeadLetterQueue.Builder<T extends EventMessage<?>>Deprecated.Builder class to instantiate anJpaSequencedDeadLetterQueue. -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedDeprecated.Instantiate a JPASequencedDeadLetterQueuebased on the givenbuilder. -
Method Summary
Modifier and TypeMethodDescriptionlongDeprecated.Returns the number of unique sequences contained in this queue.static <M extends EventMessage<?>>
JpaSequencedDeadLetterQueue.Builder<M> builder()Deprecated.Creates a new builder, capable of building aJpaSequencedDeadLetterQueueaccording to the provided configuration.voidclear()Deprecated.Clears out alldead letterspresent in this queue.booleanDeprecated.Check whether there's a sequence ofdead lettersfor the givensequenceIdentifier.Iterable<Iterable<DeadLetter<? extends M>>> Deprecated.Return alldead lettersequences held by this queue.Iterable<DeadLetter<? extends M>> deadLetterSequence(Object sequenceIdentifier) Deprecated.Return all thedead lettersfor the givensequenceIdentifierin insert order.voidenqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter) Deprecated.Enqueues adead lettercontaining an implementation ofMto this queue.voidevict(DeadLetter<? extends M> letter) Deprecated.Evict the givenletterfrom this queue.booleanDeprecated.Validates whether this queue is full for the givensequenceIdentifier.booleanprocess(Function<DeadLetter<? extends M>, EnqueueDecision<M>> processingTask) Deprecated.Process a sequence of enqueueddead letterswith the givenprocessingTask.booleanprocess(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, EnqueueDecision<M>> processingTask) Deprecated.Process a sequence of enqueueddead lettersthrough the givenprocessingTaskmatching thesequenceFilter.voidrequeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater) Deprecated.Reenters the givenletter, updating the contents with theletterUpdater.longsequenceSize(Object sequenceIdentifier) Deprecated.Returns the number of dead letters for the sequence matching the givensequenceIdentifiercontained in this queue.longsize()Deprecated.Returns the number of dead letters contained in this queue.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.axonframework.messaging.deadletter.SequencedDeadLetterQueue
enqueueIfPresent
-
Constructor Details
-
JpaSequencedDeadLetterQueue
Deprecated.Instantiate a JPASequencedDeadLetterQueuebased on the givenbuilder.- Parameters:
builder- TheJpaSequencedDeadLetterQueue.Builderused to instantiate aJpaSequencedDeadLetterQueueinstance.
-
-
Method Details
-
builder
Deprecated.Creates a new builder, capable of building aJpaSequencedDeadLetterQueueaccording to the provided configuration. Note that theJpaSequencedDeadLetterQueue.Builder.processingGroup(String),JpaSequencedDeadLetterQueue.Builder.transactionManager,JpaSequencedDeadLetterQueue.Builder.serializer(Serializer)andJpaSequencedDeadLetterQueue.Builder.entityManagerProviderare mandatory for the queue to be constructed.- Type Parameters:
M- An implementation ofMessagecontained in thedead-letterswithin this queue.- Returns:
- The builder
-
enqueue
public void enqueue(@Nonnull Object sequenceIdentifier, @Nonnull DeadLetter<? extends M> letter) throws DeadLetterQueueOverflowException Deprecated.Description copied from interface:SequencedDeadLetterQueueEnqueues adead lettercontaining an implementation ofMto this queue.The
dead letterwill be appended to a sequence depending on thesequenceIdentifier. If there is no sequence yet, it will construct one.- Specified by:
enqueuein interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
sequenceIdentifier- The identifier of the sequence theletterbelongs to.letter- TheDeadLetterto enqueue.- Throws:
DeadLetterQueueOverflowException- Thrown when this queueis full.
-
evict
Deprecated.Description copied from interface:SequencedDeadLetterQueueEvict the givenletterfrom this queue. Nothing happens if thedead letterdoes not exist in this queue.- Specified by:
evictin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
letter- Thedead letterto evict from this queue.
-
requeue
public void requeue(@Nonnull DeadLetter<? extends M> letter, @Nonnull UnaryOperator<DeadLetter<? extends M>> letterUpdater) throws NoSuchDeadLetterException Deprecated.Description copied from interface:SequencedDeadLetterQueueReenters the givenletter, updating the contents with theletterUpdater. This method should be invoked ifprocessingdecided to keep the letter in the queue.This operation adjusts the
DeadLetter.lastTouched(). It may adjust theDeadLetter.cause()andDeadLetter.diagnostics(), depending on the givenletterUpdater.- Specified by:
requeuein interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
letter- Thedead letterto reenter in this queue.letterUpdater- Alambdataking in the givenletterand updating the entry for requeueing. This may adjust theDeadLetter.cause()andDeadLetter.diagnostics(), for example.- Throws:
NoSuchDeadLetterException- Thrown if the givenletterdoes not exist in the queue.
-
contains
Deprecated.Description copied from interface:SequencedDeadLetterQueueCheck whether there's a sequence ofdead lettersfor the givensequenceIdentifier.- Specified by:
containsin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
sequenceIdentifier- The identifier used to validate for containeddead lettersinstances.- Returns:
trueif there aredead letterspresent for the givensequenceIdentifier,falseotherwise.
-
deadLetterSequence
Deprecated.Description copied from interface:SequencedDeadLetterQueueReturn all thedead lettersfor the givensequenceIdentifierin insert order.- Specified by:
deadLetterSequencein interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
sequenceIdentifier- The identifier of the sequence ofdead lettersto return.- Returns:
- All the
dead lettersfor the givensequenceIdentifierin insert order.
-
deadLetters
Deprecated.Description copied from interface:SequencedDeadLetterQueueReturn alldead lettersequences held by this queue. The sequences are not necessarily returned in insert order.- Specified by:
deadLettersin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Returns:
- All
dead lettersequences held by this queue.
-
isFull
Deprecated.Description copied from interface:SequencedDeadLetterQueueValidates whether this queue is full for the givensequenceIdentifier.This method returns
trueeither when the maximum amount of sequences or the maximum sequence size is reached.- Specified by:
isFullin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
sequenceIdentifier- The identifier of the sequence to validate for.- Returns:
trueeither when the limit of this queue is reached. Returnsfalseotherwise.
-
process
public boolean process(@Nonnull Predicate<DeadLetter<? extends M>> sequenceFilter, @Nonnull Function<DeadLetter<? extends M>, EnqueueDecision<M>> processingTask) Deprecated.Description copied from interface:SequencedDeadLetterQueueProcess a sequence of enqueueddead lettersthrough the givenprocessingTaskmatching thesequenceFilter. Will pick the oldest available sequence based on theDeadLetter.lastTouched()field from every sequence's first entry.Note that only a single matching sequence is processed! Furthermore, only the first dead letter is validated, because it is the blocker for the processing of the rest of the sequence.
Uses the
EnqueueDecisionreturned by theprocessingTaskto decide whether toSequencedDeadLetterQueue.evict(DeadLetter)orSequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator)a dead letter from the selected sequence. TheprocessingTaskis invoked as long as letters are present in the selected sequence and the result of processing returnsfalseforEnqueueDecision.shouldEnqueue()decision. The latter means the dead letter should be evicted.This operation protects against concurrent invocations of the
processingTaskon the filtered sequence. Doing so ensure enqueued messages are handled in order.- Specified by:
processin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
sequenceFilter- Alambdaselecting the sequences within this queue to process with theprocessingTask.processingTask- A function processing adead letter. Returns aEnqueueDecisionused to deduce whether toSequencedDeadLetterQueue.evict(DeadLetter)orSequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator)the dead letter.- Returns:
trueif an entire sequence ofdead letterswas processed successfully,falseotherwise. This means theprocessingTaskprocessed alldead lettersof a sequence and the outcome was to evict each instance.
-
process
public boolean process(@Nonnull Function<DeadLetter<? extends M>, EnqueueDecision<M>> processingTask) Deprecated.Description copied from interface:SequencedDeadLetterQueueProcess a sequence of enqueueddead letterswith the givenprocessingTask. Will pick the oldest available sequence based on theDeadLetter.lastTouched()field from every sequence's first entry.Note that only a single matching sequence is processed!
Uses the
EnqueueDecisionreturned by theprocessingTaskto decide whether toSequencedDeadLetterQueue.evict(DeadLetter)orSequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator)the dead letter. TheprocessingTaskis invoked as long as letters are present in the selected sequence and the result of processing returnsfalseforEnqueueDecision.shouldEnqueue()decision. The latter means the dead letter should be evicted.This operation protects against concurrent invocations of the
processingTaskon the filtered sequence. * Doing so ensure enqueued messages are handled in order.- Specified by:
processin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
processingTask- A function processing adead letter. Returns aEnqueueDecisionused to deduce whether toSequencedDeadLetterQueue.evict(DeadLetter)orSequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator)the dead letter.- Returns:
trueif an entire sequence ofdead letterswas processed successfully,falseotherwise. This means theprocessingTaskprocessed alldead lettersof a sequence and the outcome was to evict each instance.
-
clear
public void clear()Deprecated.Description copied from interface:SequencedDeadLetterQueueClears out alldead letterspresent in this queue.- Specified by:
clearin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>
-
sequenceSize
Deprecated.Description copied from interface:SequencedDeadLetterQueueReturns the number of dead letters for the sequence matching the givensequenceIdentifiercontained in this queue.Note that there's a window of opportunity where the size might exceed the maximum sequence size to accompany concurrent usage.
- Specified by:
sequenceSizein interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Parameters:
sequenceIdentifier- The identifier of the sequence to retrieve the size from.- Returns:
- The number of dead letters for the sequence matching the given
sequenceIdentifier.
-
size
public long size()Deprecated.Description copied from interface:SequencedDeadLetterQueueReturns the number of dead letters contained in this queue.- Specified by:
sizein interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Returns:
- The number of dead letters contained in this queue.
-
amountOfSequences
public long amountOfSequences()Deprecated.Description copied from interface:SequencedDeadLetterQueueReturns the number of unique sequences contained in this queue.Note that there's a window of opportunity where the size might exceed the maximum amount of sequences to accompany concurrent usage of this dead letter queue.
- Specified by:
amountOfSequencesin interfaceSequencedDeadLetterQueue<M extends EventMessage<?>>- Returns:
- The number of unique sequences contained in this queue.
-
JpaSequencedDeadLetterQueuewhich moved to jakarta.