M
- An implementation of Message
contained in the processed dead letters
.public interface SequencedDeadLetterProcessor<M extends Message<?>>
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.
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. |
boolean process(Predicate<DeadLetter<? extends M>> sequenceFilter)
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.
sequenceFilter
- A filter for the first dead letter
entries of each sequence.true
if at least one dead letter
was processed successfully, false
otherwise.default boolean processAny()
dead letters
belonging to this component.
Note that only a single matching sequence is processed!
true
if at least one dead letter
was processed successfully, false
otherwise.Copyright © 2010–2023. All rights reserved.