Uses of Interface
io.axoniq.framework.messaging.deadletter.DeadLetter

Packages that use DeadLetter

Package	Description
io.axoniq.framework.messaging.deadletter	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventhandling.deadletter	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventhandling.deadletter.jdbc	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventhandling.deadletter.jpa	Part of the Axon Messaging module.
io.axoniq.framework.messaging.multitenancy.deadletter	Integrates dead-letter queue handling with multi-tenant event processing.

Uses of DeadLetter in io.axoniq.framework.messaging.deadletter

Classes in io.axoniq.framework.messaging.deadletter that implement DeadLetter

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

Fields in io.axoniq.framework.messaging.deadletter with type parameters of type DeadLetter

Modifier and Type	Field	Description
static final Context.ResourceKey<DeadLetter<?>>	DeadLetter.RESOURCE_KEY	The Context.ResourceKey used whenever a Context would contain a DeadLetter.

Methods in io.axoniq.framework.messaging.deadletter that return DeadLetter

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

Methods in io.axoniq.framework.messaging.deadletter that return types with arguments of type DeadLetter

Modifier and Type	Method	Description
@Nullable ParameterResolver<DeadLetter<?>>	DeadLetterParameterResolverFactory.createInstance(Executable executable, Parameter[] parameters, int parameterIndex)
CompletableFuture<Iterable<Iterable<DeadLetter<? extends M>>>>	InMemorySequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)
CompletableFuture<Iterable<Iterable<DeadLetter<? extends M>>>>	SequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)	Return all dead letter sequences held by this queue.
CompletableFuture<Iterable<DeadLetter<? extends M>>>	InMemorySequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)
CompletableFuture<Iterable<DeadLetter<? extends M>>>	SequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)	Return all the dead letters for the given sequenceIdentifier in insert order.
static Optional<DeadLetter<?>>	DeadLetter.fromContext(Context context)	Returns an Optional of {DeadLetter}, returning the resource keyed under the RESOURCE_KEY in the given context.

Methods in io.axoniq.framework.messaging.deadletter with parameters of type DeadLetter

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

Method parameters in io.axoniq.framework.messaging.deadletter with type arguments of type DeadLetter

Modifier and Type	Method	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 CompletableFuture<Boolean>	SequencedDeadLetterQueue.enqueueIfPresent(Object sequenceIdentifier, Supplier<DeadLetter<? extends M>> letterBuilder, @Nullable ProcessingContext context)	Enqueue the result of the given letterBuilder only if there already are other dead letters with the same sequenceIdentifier present in this queue.
CompletableFuture<Boolean>	InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	SequencedDeadLetterProcessor.process(Predicate<DeadLetter<? extends M>> sequenceFilter)	Process a sequence of dead letters matching the given sequenceFilter.
default CompletableFuture<Boolean>	SequencedDeadLetterProcessor.process(Predicate<DeadLetter<? extends M>> sequenceFilter, @Nullable ProcessingContext context)	Process a sequence of dead letters matching the given sequenceFilter.
default CompletableFuture<Boolean>	SequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)	Process a single sequence of enqueued dead letters with the given processingTask.
CompletableFuture<Boolean>	SequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)	Process a single sequence of enqueued dead letters through the given processingTask matching the sequenceFilter.
CompletableFuture<Boolean>	SequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)	Process a single sequence of enqueued dead letters through the given processingTask matching the sequenceFilter.
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.
CompletableFuture<Void>	InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)
CompletableFuture<Void>	SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)	Reenters the given letter, updating the contents with the letterUpdater.

Constructor parameters in io.axoniq.framework.messaging.deadletter with type arguments of type DeadLetter

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

Uses of DeadLetter in io.axoniq.framework.messaging.eventhandling.deadletter

Methods in io.axoniq.framework.messaging.eventhandling.deadletter that return types with arguments of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Iterable<Iterable<DeadLetter<? extends M>>>>	CachingSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)
CompletableFuture<Iterable<DeadLetter<? extends M>>>	CachingSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)

Methods in io.axoniq.framework.messaging.eventhandling.deadletter with parameters of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Void>	CachingSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	CachingSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	CachingSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)

Method parameters in io.axoniq.framework.messaging.eventhandling.deadletter with type arguments of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Boolean>	CachingSequencedDeadLetterQueue.enqueueIfPresent(Object sequenceIdentifier, Supplier<DeadLetter<? extends M>> letterBuilder, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	CachingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	CachingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	DeadLetteringEventHandlingComponent.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter)
CompletableFuture<Boolean>	DeadLetteringEventHandlingComponent.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, @Nullable ProcessingContext context)
CompletableFuture<Void>	CachingSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)

Uses of DeadLetter in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc

Classes in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc that implement DeadLetter

Modifier and Type	Class	Description
class	JdbcDeadLetter<E extends EventMessage>	A DeadLetter that was saved to a JDBC-backed database and reconstructed from it.

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc that return DeadLetter

Modifier and Type	Method	Description
DeadLetter<E>	JdbcDeadLetter.markTouched()
DeadLetter<E>	JdbcDeadLetter.withCause(Throwable requeueCause)
DeadLetter<E>	JdbcDeadLetter.withDiagnostics(Metadata diagnostics)

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc that return types with arguments of type DeadLetter

Modifier and Type	Method	Description
@NonNull CompletableFuture<Iterable<Iterable<DeadLetter<? extends E>>>>	JdbcSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)
CompletableFuture<Iterable<DeadLetter<? extends E>>>	JdbcSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc with parameters of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Void>	JdbcSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends E> letter, @Nullable ProcessingContext context)
PreparedStatement	DeadLetterStatementFactory.enqueueStatement(Connection connection, String processingGroup, String sequenceIdentifier, DeadLetter<? extends E> letter, long sequenceIndex)	Constructs the PreparedStatement used for the JdbcSequencedDeadLetterQueue.enqueue(Object, DeadLetter, org.axonframework.messaging.core.unitofwork.ProcessingContext) operation.
PreparedStatement	DefaultDeadLetterStatementFactory.enqueueStatement(Connection connection, String processingGroup, String sequenceIdentifier, DeadLetter<? extends E> letter, long sequenceIndex)
@NonNull CompletableFuture<Void>	JdbcSequencedDeadLetterQueue.evict(@NonNull DeadLetter<? extends E> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	JdbcSequencedDeadLetterQueue.requeue(DeadLetter<? extends E> letter, UnaryOperator<DeadLetter<? extends E>> letterUpdater, @Nullable ProcessingContext context)

Method parameters in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc with type arguments of type DeadLetter

Modifier and Type	Method	Description
@NonNull CompletableFuture<Boolean>	JdbcSequencedDeadLetterQueue.process(@NonNull Predicate<DeadLetter<? extends E>> sequenceFilter, @NonNull Function<DeadLetter<? extends E>,CompletableFuture<EnqueueDecision<E>>> processingTask, @Nullable ProcessingContext context)
@NonNull CompletableFuture<Boolean>	JdbcSequencedDeadLetterQueue.process(@NonNull Predicate<DeadLetter<? extends E>> sequenceFilter, @NonNull Function<DeadLetter<? extends E>,CompletableFuture<EnqueueDecision<E>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	JdbcSequencedDeadLetterQueue.process(Function<DeadLetter<? extends E>,CompletableFuture<EnqueueDecision<E>>> processingTask, @Nullable ProcessingContext context)	Process a single sequence of enqueued dead letters with the given processingTask.
CompletableFuture<Void>	JdbcSequencedDeadLetterQueue.requeue(DeadLetter<? extends E> letter, UnaryOperator<DeadLetter<? extends E>> letterUpdater, @Nullable ProcessingContext context)

Uses of DeadLetter in io.axoniq.framework.messaging.eventhandling.deadletter.jpa

Classes in io.axoniq.framework.messaging.eventhandling.deadletter.jpa that implement DeadLetter

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

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jpa that return DeadLetter

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

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jpa that return types with arguments of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Iterable<Iterable<DeadLetter<? extends M>>>>	JpaSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)
CompletableFuture<Iterable<DeadLetter<? extends M>>>	JpaSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jpa with parameters of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Void>	JpaSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	JpaSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)

Method parameters in io.axoniq.framework.messaging.eventhandling.deadletter.jpa with type arguments of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Boolean>	JpaSequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)	Process a single sequence of enqueued dead letters with the given processingTask.
CompletableFuture<Boolean>	JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Void>	JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)

Uses of DeadLetter in io.axoniq.framework.messaging.multitenancy.deadletter

Methods in io.axoniq.framework.messaging.multitenancy.deadletter that return types with arguments of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Iterable<Iterable<DeadLetter<? extends EventMessage>>>>	TenantRoutingSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context)
CompletableFuture<Iterable<DeadLetter<? extends EventMessage>>>	TenantRoutingSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context)

Methods in io.axoniq.framework.messaging.multitenancy.deadletter with parameters of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends EventMessage> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.evict(DeadLetter<? extends EventMessage> letter, @Nullable ProcessingContext context)
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.requeue(DeadLetter<? extends EventMessage> letter, UnaryOperator<DeadLetter<? extends EventMessage>> letterUpdater, @Nullable ProcessingContext context)

Method parameters in io.axoniq.framework.messaging.multitenancy.deadletter with type arguments of type DeadLetter

Modifier and Type	Method	Description
CompletableFuture<Boolean>	TenantRoutingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, Function<DeadLetter<? extends EventMessage>,CompletableFuture<EnqueueDecision<EventMessage>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Boolean>	TenantRoutingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter, Function<DeadLetter<? extends EventMessage>,CompletableFuture<EnqueueDecision<EventMessage>>> processingTask, @Nullable ProcessingContext context)
CompletableFuture<Void>	TenantRoutingSequencedDeadLetterQueue.requeue(DeadLetter<? extends EventMessage> letter, UnaryOperator<DeadLetter<? extends EventMessage>> letterUpdater, @Nullable ProcessingContext context)