org.axonframework.messaging.deadletter

Interface DeadLetter<M extends Message<?>>

Type Parameters:

M - The type of Message represented by this interface.

All Known Implementing Classes:

GenericDeadLetter, JpaDeadLetter

public interface DeadLetter<M extends Message<?>>

Interface describing a dead lettered Message implementation of generic type M.

The time of storing the message() is kept through enqueuedAt(). The last time this letter was accessed on either SequencedDeadLetterQueue.requeue(DeadLetter, UnaryOperator) or processing, is kept in lastTouched(). Additional information on why the letter is enqueued can be found in the diagnostics.

Since:

4.6.0

Author:

Steven van Beelen, Allard Buijze

Method Summary

Modifier and Type	Method and Description
Optional<Cause>	cause() The cause for the message() to be dead lettered.
MetaData	diagnostics() The diagnostic MetaData concerning this letter.
Instant	enqueuedAt() The moment in time when the message() was entered in a dead letter queue.
Instant	lastTouched() The moment in time when this letter was last touched.
DeadLetter<M>	markTouched() Construct a copy of this DeadLetter, replacing the lastTouched() with the current time.
M	message() The Message of type M contained in this letter.
DeadLetter<M>	withCause(Throwable requeueCause) Construct a copy of this DeadLetter, replacing the cause() with the given requeueCause.
DeadLetter<M>	withDiagnostics(MetaData diagnostics) Construct a copy of this DeadLetter, replacing the diagnostics() with the given diagnostics.
default DeadLetter<M>	withDiagnostics(UnaryOperator<MetaData> diagnosticsBuilder) Construct a copy of this DeadLetter, replacing the diagnostics() with the result of the given diagnosticsBuilder.

Method Detail

message

M message()

The Message of type M contained in this letter.

Returns:

The Message of type M contained in this letter.

cause

Optional<Cause> cause()

The cause for the message() to be dead lettered. Can be an Optional.empty() in case this letter is enqueued without a causal error. For instance, when another letter already present in the queue was blocking it being handled.

Returns:

The cause for the message() to be dead lettered.

enqueuedAt

Instant enqueuedAt()

The moment in time when the message() was entered in a dead letter queue.

Returns:

The moment in time when the message() was entered in a dead letter queue.

lastTouched

Instant lastTouched()

The moment in time when this letter was last touched. Will equal the enqueuedAt() value if this letter is enqueued for the first time.

Returns:

The moment in time when this letter was last touched.

diagnostics

MetaData diagnostics()

The diagnostic MetaData concerning this letter.

Returns:

The diagnostic MetaData concerning this letter.

markTouched

DeadLetter<M> markTouched()

Construct a copy of this DeadLetter, replacing the lastTouched() with the current time.

Returns:

A copy of this DeadLetter with lastTouched() set to now.

withCause

DeadLetter<M> withCause(Throwable requeueCause)

Construct a copy of this DeadLetter, replacing the cause() with the given requeueCause.

Parameters:

requeueCause - The new cause of the DeadLetter under construction.

Returns:

A copy of this DeadLetter, replacing the cause() with the given requeueCause.

withDiagnostics

DeadLetter<M> withDiagnostics(MetaData diagnostics)

Construct a copy of this DeadLetter, replacing the diagnostics() with the given diagnostics.

Parameters:

diagnostics - The diagnostic MetaData to append to the DeadLetter under construction.

Returns:

A copy of this DeadLetter, replacing the diagnostics() with the given diagnostics.

withDiagnostics

default DeadLetter<M> withDiagnostics(UnaryOperator<MetaData> diagnosticsBuilder)

Construct a copy of this DeadLetter, replacing the diagnostics() with the result of the given diagnosticsBuilder. The diagnosticsBuilder will be invoked with the diagnostics of this instance.

Parameters:

diagnosticsBuilder - The lambda constructing diagnostic MetaData to replace the MetaData of the DeadLetter under construction.

Returns:

A copy of this DeadLetter, replacing the diagnostics() with the result of the given diagnosticsBuilder.