Package org.axonframework.messaging.deadletter

Class InMemorySequencedDeadLetterQueue<M extends Message<?>>

java.lang.Object

org.axonframework.messaging.deadletter.InMemorySequencedDeadLetterQueue<M>

Type Parameters:

M - The type of Message maintained in the dead letter of this SequencedDeadLetterQueue.

All Implemented Interfaces:

SequencedDeadLetterQueue<M>

public class InMemorySequencedDeadLetterQueue<M extends Message<?>>
extends Object
implements SequencedDeadLetterQueue<M>

In-memory implementation of the SequencedDeadLetterQueue.

Maintains a Deque per unique "sequence identifier." The maximum amount of Deques contained by this SequencedDeadLetterQueue is 1024 (configurable through InMemorySequencedDeadLetterQueue.Builder.maxSequences(int)). The maximum amount of dead letters per sequence also defaults to 1024 (configurable through InMemorySequencedDeadLetterQueue.Builder.maxSequenceSize(int)).

Since:

4.6.0

Author:

Steven van Beelen

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	InMemorySequencedDeadLetterQueue.Builder<M extends Message<?>>	Builder class to instantiate an InMemorySequencedDeadLetterQueue.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InMemorySequencedDeadLetterQueue(InMemorySequencedDeadLetterQueue.Builder<M> builder)	Instantiate an in-memory SequencedDeadLetterQueue based on the given builder.

Method Summary

Modifier and Type	Method	Description
long	amountOfSequences()	Returns the number of unique sequences contained in this queue.
static <M extends Message<?>> InMemorySequencedDeadLetterQueue.Builder<M>	builder()	Instantiate a builder to construct an InMemorySequencedDeadLetterQueue.
void	clear()	Clears out all dead letters present in this queue.
boolean	contains(Object sequenceIdentifier)	Check whether there's a sequence of dead letters for the given sequenceIdentifier.
Iterable<Iterable<DeadLetter<? extends M>>>	deadLetters()	Return all dead letter sequences held by this queue.
Iterable<DeadLetter<? extends M>>	deadLetterSequence(Object sequenceIdentifier)	Return all the dead letters for the given sequenceIdentifier in insert order.
static <M extends Message<?>> InMemorySequencedDeadLetterQueue<M>	defaultQueue()	Construct a default InMemorySequencedDeadLetterQueue.
void	enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter)	Enqueues a dead letter containing an implementation of M to this queue.
void	evict(DeadLetter<? extends M> letter)	Evict the given letter from this queue.
boolean	isFull(Object sequenceIdentifier)	Validates whether this queue is full for the given sequenceIdentifier.
boolean	process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)	Process a sequence of enqueued dead letters through the given processingTask matching the sequenceFilter.
void	requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater)	Reenters the given letter, updating the contents with the letterUpdater.
long	sequenceSize(Object sequenceIdentifier)	Returns the number of dead letters for the sequence matching the given sequenceIdentifier contained in this queue.
long	size()	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, wait

Methods inherited from interface org.axonframework.messaging.deadletter.SequencedDeadLetterQueue

enqueueIfPresent, process

Constructor Details

InMemorySequencedDeadLetterQueue

protected InMemorySequencedDeadLetterQueue(InMemorySequencedDeadLetterQueue.Builder<M> builder)

Instantiate an in-memory SequencedDeadLetterQueue based on the given builder.

Parameters:

builder - The InMemorySequencedDeadLetterQueue.Builder used to instantiate a InMemorySequencedDeadLetterQueue instance.

Method Details

builder

public static <M extends Message<?>>
InMemorySequencedDeadLetterQueue.Builder<M> builder()

Instantiate a builder to construct an InMemorySequencedDeadLetterQueue.

The maximum number of sequences defaults to 1024 and the maximum amount of dead letters inside a sequence defaults to 1024.

Type Parameters:

M - The type of Message maintained in the dead letter of this SequencedDeadLetterQueue.

Returns:

A Builder that can construct an InMemorySequencedDeadLetterQueue.

defaultQueue

public static <M extends Message<?>>
InMemorySequencedDeadLetterQueue<M> defaultQueue()

Construct a default InMemorySequencedDeadLetterQueue.

The maximum number of sequences defaults to 1024 and the maximum amount of dead letters inside a sequence defaults to 1024.

Type Parameters:

M - The type of Message maintained in the dead letter of this SequencedDeadLetterQueue.

Returns:

A default InMemorySequencedDeadLetterQueue.

enqueue

public void enqueue(@Nonnull
 Object sequenceIdentifier,
 @Nonnull
 DeadLetter<? extends M> letter)
             throws DeadLetterQueueOverflowException

Description copied from interface: SequencedDeadLetterQueue

Enqueues a dead letter containing an implementation of M to this queue.

The dead letter will be appended to a sequence depending on the sequenceIdentifier. If there is no sequence yet, it will construct one.

Specified by:

enqueue in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

sequenceIdentifier - The identifier of the sequence the letter belongs to.

letter - The DeadLetter to enqueue.

Throws:

DeadLetterQueueOverflowException - Thrown when this queue is full.

evict

public void evict(DeadLetter<? extends M> letter)

Description copied from interface: SequencedDeadLetterQueue

Evict the given letter from this queue. Nothing happens if the dead letter does not exist in this queue.

Specified by:

evict in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

letter - The dead letter to evict from this queue.

requeue

public void requeue(@Nonnull
 DeadLetter<? extends M> letter,
 @Nonnull
 UnaryOperator<DeadLetter<? extends M>> letterUpdater)
             throws NoSuchDeadLetterException

Description copied from interface: SequencedDeadLetterQueue

Reenters the given letter, updating the contents with the letterUpdater. This method should be invoked if processing decided to keep the letter in the queue.

This operation adjusts the DeadLetter.lastTouched(). It may adjust the DeadLetter.cause() and DeadLetter.diagnostics(), depending on the given letterUpdater.

Specified by:

requeue in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

letter - The dead letter to reenter in this queue.

letterUpdater - A lambda taking in the given letter and updating the entry for requeueing. This may adjust the DeadLetter.cause() and DeadLetter.diagnostics(), for example.

Throws:

NoSuchDeadLetterException - Thrown if the given letter does not exist in the queue.

contains

public boolean contains(@Nonnull
 Object sequenceIdentifier)

Description copied from interface: SequencedDeadLetterQueue

Check whether there's a sequence of dead letters for the given sequenceIdentifier.

Specified by:

contains in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

sequenceIdentifier - The identifier used to validate for contained dead letters instances.

Returns:

true if there are dead letters present for the given sequenceIdentifier, false otherwise.

deadLetterSequence

public Iterable<DeadLetter<? extends M>> deadLetterSequence(@Nonnull
 Object sequenceIdentifier)

Description copied from interface: SequencedDeadLetterQueue

Return all the dead letters for the given sequenceIdentifier in insert order.

Specified by:

deadLetterSequence in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

sequenceIdentifier - The identifier of the sequence of dead lettersto return.

Returns:

All the dead letters for the given sequenceIdentifier in insert order.

deadLetters

public Iterable<Iterable<DeadLetter<? extends M>>> deadLetters()

Description copied from interface: SequencedDeadLetterQueue

Return all dead letter sequences held by this queue. The sequences are not necessarily returned in insert order.

Specified by:

deadLetters in interface SequencedDeadLetterQueue<M extends Message<?>>

Returns:

All dead letter sequences held by this queue.

isFull

public boolean isFull(@Nonnull
 Object sequenceIdentifier)

Description copied from interface: SequencedDeadLetterQueue

Validates whether this queue is full for the given sequenceIdentifier.

This method returns true either when the maximum amount of sequences or the maximum sequence size is reached.

Specified by:

isFull in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

sequenceIdentifier - The identifier of the sequence to validate for.

Returns:

true either when the limit of this queue is reached. Returns false otherwise.

size

public long size()

Description copied from interface: SequencedDeadLetterQueue

Returns the number of dead letters contained in this queue.

Specified by:

size in interface SequencedDeadLetterQueue<M extends Message<?>>

Returns:

The number of dead letters contained in this queue.

sequenceSize

public long sequenceSize(@Nonnull
 Object sequenceIdentifier)

Description copied from interface: SequencedDeadLetterQueue

Returns the number of dead letters for the sequence matching the given sequenceIdentifier contained 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:

sequenceSize in interface SequencedDeadLetterQueue<M extends Message<?>>

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.

amountOfSequences

public long amountOfSequences()

Description copied from interface: SequencedDeadLetterQueue

Returns 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:

amountOfSequences in interface SequencedDeadLetterQueue<M extends Message<?>>

Returns:

The number of unique sequences contained in this queue.

process

public boolean process(@Nonnull
 Predicate<DeadLetter<? extends M>> sequenceFilter,
 @Nonnull
 Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)

Description copied from interface: SequencedDeadLetterQueue

Process a sequence of enqueued dead letters through the given processingTask matching the sequenceFilter. Will pick the oldest available sequence based on the DeadLetter.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 EnqueueDecision returned by the processingTask to decide whether to SequencedDeadLetterQueue.evict(DeadLetter) or SequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator) a dead letter from the selected sequence. The processingTask is invoked as long as letters are present in the selected sequence and the result of processing returns false for EnqueueDecision.shouldEnqueue() decision. The latter means the dead letter should be evicted.

This operation protects against concurrent invocations of the processingTask on the filtered sequence. Doing so ensure enqueued messages are handled in order.

Specified by:

process in interface SequencedDeadLetterQueue<M extends Message<?>>

Parameters:

sequenceFilter - A lambda selecting the sequences within this queue to process with the processingTask.

processingTask - A function processing a dead letter. Returns a EnqueueDecision used to deduce whether to SequencedDeadLetterQueue.evict(DeadLetter) or SequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator) the dead letter.

Returns:

true if an entire sequence of dead letters was processed successfully, false otherwise. This means the processingTask processed all dead letters of a sequence and the outcome was to evict each instance.

clear

public void clear()

Description copied from interface: SequencedDeadLetterQueue

Clears out all dead letters present in this queue.

Specified by:

clear in interface SequencedDeadLetterQueue<M extends Message<?>>