org.axonframework.messaging.deadletter

Interface SequencedDeadLetterProcessor<M extends Message<?>>

Type Parameters:

M - An implementation of Message contained in the processed dead letters.

All Known Implementing Classes:

DeadLetteringEventHandlerInvoker

public interface SequencedDeadLetterProcessor<M extends Message<?>>

Contract describing a component that can process dead letters that it has enqueued.

Should use the SequencedDeadLetterQueue for processing as this ensures dead lettered Messages are kept in sequence. Thus processed in order through this component.

Since:

4.6.0

Author:

Steven van Beelen

Method Summary

Modifier and Type	Method and Description
boolean	process(Predicate<DeadLetter<? extends M>> sequenceFilter) Process a sequence of dead letters matching the given sequenceFilter.
default boolean	processAny() Process any sequence of dead letters belonging to this component.

Method Detail

process

boolean process(Predicate<DeadLetter<? extends M>> sequenceFilter)

Process a sequence of dead letters matching the given sequenceFilter.

Note that only a single matching sequence is processed! Furthermore, the sequenceFilter is only invoked for the first letter of a sequence, as the first entry blocks the entire sequence.

Parameters:

sequenceFilter - A filter for the first dead letter entries of each sequence.

Returns:

true if at least one dead letter was processed successfully, false otherwise.

processAny

default boolean processAny()

Process any sequence of dead letters belonging to this component.

Note that only a single matching sequence is processed!

Returns:

true if at least one dead letter was processed successfully, false otherwise.