Uses of Interface
org.axonframework.messaging.deadletter.DeadLetter

Packages that use DeadLetter

Package	Description
org.axonframework.eventhandling.deadletter
org.axonframework.eventhandling.deadletter.jpa
org.axonframework.messaging.deadletter

Uses of DeadLetter in org.axonframework.eventhandling.deadletter

Method parameters in org.axonframework.eventhandling.deadletter with type arguments of type DeadLetter

Modifier and Type	Method and Description
boolean	DeadLetteringEventHandlerInvoker.process(Predicate<DeadLetter<? extends EventMessage<?>>> sequenceFilter)

Uses of DeadLetter in org.axonframework.eventhandling.deadletter.jpa

Classes in org.axonframework.eventhandling.deadletter.jpa that implement DeadLetter

Modifier and Type	Class and Description
class	JpaDeadLetter<M extends EventMessage<?>> A DeadLetter that was saved to the database and reconstructed from it.

Methods in org.axonframework.eventhandling.deadletter.jpa that return DeadLetter

Modifier and Type	Method and Description
DeadLetter<M>	JpaDeadLetter.markTouched()
DeadLetter<M>	JpaDeadLetter.withCause(Throwable requeueCause)
DeadLetter<M>	JpaDeadLetter.withDiagnostics(MetaData diagnostics)

Methods in org.axonframework.eventhandling.deadletter.jpa that return types with arguments of type DeadLetter

Modifier and Type	Method and Description
Iterable<Iterable<DeadLetter<? extends M>>>	JpaSequencedDeadLetterQueue.deadLetters()
Iterable<DeadLetter<? extends M>>	JpaSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier)

Methods in org.axonframework.eventhandling.deadletter.jpa with parameters of type DeadLetter

Modifier and Type	Method and Description
void	JpaSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter)
void	JpaSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter)
void	JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater)

Method parameters in org.axonframework.eventhandling.deadletter.jpa with type arguments of type DeadLetter

Modifier and Type	Method and Description
boolean	JpaSequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
boolean	JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
boolean	JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
void	JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater)

Uses of DeadLetter in org.axonframework.messaging.deadletter

Classes in org.axonframework.messaging.deadletter that implement DeadLetter

Modifier and Type	Class and Description
class	GenericDeadLetter<M extends Message<?>> Generic implementation of the dead letter allowing any type of Message to be dead lettered.

Methods in org.axonframework.messaging.deadletter that return DeadLetter

Modifier and Type	Method and Description
DeadLetter<M>	GenericDeadLetter.markTouched()
DeadLetter<M>	DeadLetter.markTouched() Construct a copy of this DeadLetter, replacing the lastTouched() with the current time.
DeadLetter<M>	GenericDeadLetter.withCause(Throwable requeueCause)
DeadLetter<M>	DeadLetter.withCause(Throwable requeueCause) Construct a copy of this DeadLetter, replacing the cause() with the given requeueCause.
DeadLetter<? extends M>	ShouldEnqueue.withDiagnostics(DeadLetter<? extends M> letter)
default DeadLetter<? extends M>	EnqueueDecision.withDiagnostics(DeadLetter<? extends M> letter) Adds diagnostics() MetaData to the given letter.
DeadLetter<M>	GenericDeadLetter.withDiagnostics(MetaData diagnostics)
DeadLetter<M>	DeadLetter.withDiagnostics(MetaData diagnostics) Construct a copy of this DeadLetter, replacing the diagnostics() with the given diagnostics.
default DeadLetter<M>	DeadLetter.withDiagnostics(UnaryOperator<MetaData> diagnosticsBuilder) Construct a copy of this DeadLetter, replacing the diagnostics() with the result of the given diagnosticsBuilder.

Methods in org.axonframework.messaging.deadletter that return types with arguments of type DeadLetter

Modifier and Type	Method and Description
Iterable<Iterable<DeadLetter<? extends M>>>	SequencedDeadLetterQueue.deadLetters() Return all dead letter sequences held by this queue.
Iterable<Iterable<DeadLetter<? extends M>>>	InMemorySequencedDeadLetterQueue.deadLetters()
Iterable<DeadLetter<? extends M>>	SequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier) Return all the dead letters for the given sequenceIdentifier in insert order.
Iterable<DeadLetter<? extends M>>	InMemorySequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier)

Methods in org.axonframework.messaging.deadletter with parameters of type DeadLetter

Modifier and Type	Method and Description
EnqueueDecision<M>	EnqueuePolicy.decide(DeadLetter<? extends M> letter, Throwable cause) Constructs a EnqueueDecision based on the given letter and cause.
void	SequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter) Enqueues a dead letter containing an implementation of M to this queue.
void	InMemorySequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter)
void	SequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter) Evict the given letter from this queue.
void	InMemorySequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter)
void	SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater) Reenters the given letter, updating the contents with the letterUpdater.
void	InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater)
DeadLetter<? extends M>	ShouldEnqueue.withDiagnostics(DeadLetter<? extends M> letter)
default DeadLetter<? extends M>	EnqueueDecision.withDiagnostics(DeadLetter<? extends M> letter) Adds diagnostics() MetaData to the given letter.

Method parameters in org.axonframework.messaging.deadletter with type arguments of type DeadLetter

Modifier and Type	Method and Description
static <M extends Message<?>> ShouldEnqueue<M>	Decisions.enqueue(Throwable enqueueCause, Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder) Construct a ShouldEnqueue defining that a dead letter should be enqueued because of the given enqueueCause.
default boolean	SequencedDeadLetterQueue.enqueueIfPresent(Object sequenceIdentifier, Supplier<DeadLetter<? extends M>> letterBuilder) Enqueue the result of the given letterBuilder only if there already are other dead letters with the same sequenceIdentifier present in this queue.
default boolean	SequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask) Process a sequence of enqueued dead letters with the given processingTask.
boolean	SequencedDeadLetterProcessor.process(Predicate<DeadLetter<? extends M>> sequenceFilter) Process a sequence of dead letters matching the given sequenceFilter.
boolean	SequencedDeadLetterQueue.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.
boolean	SequencedDeadLetterQueue.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.
boolean	InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
boolean	InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
void	SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater) Reenters the given letter, updating the contents with the letterUpdater.
void	InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater)
static <M extends Message<?>> ShouldEnqueue<M>	Decisions.requeue(Throwable requeueCause, Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder) Construct a ShouldEnqueue defining that a dead letter should be requeued because of the given requeueCause.

Constructor parameters in org.axonframework.messaging.deadletter with type arguments of type DeadLetter

Constructor and Description
ShouldEnqueue(Throwable enqueueCause, Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder) Constructs a default EnqueueDecision to enqueue using the given enqueueCause as the ShouldEnqueue.enqueueCause().