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

Packages that use EnqueueDecision

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.

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

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

Modifier and Type	Class	Description
class	DoNotEnqueue<M extends Message>	An EnqueueDecision stating a dead letter should not be enqueued.
class	Ignore<M extends Message>	An EnqueueDecision stating a dead letter should be ignored.
class	ShouldEnqueue<M extends Message>	An EnqueueDecision stating a dead letter should be enqueued.

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

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.

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

Modifier and Type	Method	Description
CompletableFuture<Boolean>	InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)
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.

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

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

Modifier and Type	Method	Description
CompletableFuture<Boolean>	CachingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>,CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)

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

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

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)
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.

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

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

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)