Uses of Interface
org.axonframework.messaging.deadletter.EnqueueDecision
Packages that use EnqueueDecision
Package
Description
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
-
Uses of EnqueueDecision in org.axonframework.messaging.deadletter
Classes in org.axonframework.messaging.deadletter that implement EnqueueDecisionModifier and TypeClassDescriptionclassDoNotEnqueue<M extends Message>AnEnqueueDecisionstating adead lettershould not be enqueued.classAnEnqueueDecisionstating adead lettershould be ignored.classShouldEnqueue<M extends Message>AnEnqueueDecisionstating adead lettershould be enqueued.Methods in org.axonframework.messaging.deadletter that return EnqueueDecisionModifier and TypeMethodDescriptionEnqueuePolicy.decide(DeadLetter<? extends M> letter, Throwable cause) Method parameters in org.axonframework.messaging.deadletter with type arguments of type EnqueueDecisionModifier and TypeMethodDescriptionInMemorySequencedDeadLetterQueue.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 enqueueddead letterswith the givenprocessingTask.SequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) Process a single sequence of enqueueddead lettersthrough the givenprocessingTaskmatching thesequenceFilter. -
Uses of EnqueueDecision in org.axonframework.messaging.eventhandling.deadletter
Method parameters in org.axonframework.messaging.eventhandling.deadletter with type arguments of type EnqueueDecisionModifier and TypeMethodDescriptionCachingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) -
Uses of EnqueueDecision in org.axonframework.messaging.eventhandling.deadletter.jdbc
Method parameters in org.axonframework.messaging.eventhandling.deadletter.jdbc with type arguments of type EnqueueDecisionModifier and TypeMethodDescription@NonNull CompletableFuture<Boolean> JdbcSequencedDeadLetterQueue.process(@NonNull Predicate<DeadLetter<? extends E>> sequenceFilter, @NonNull Function<DeadLetter<? extends E>, CompletableFuture<EnqueueDecision<E>>> processingTask, @Nullable ProcessingContext context) JdbcSequencedDeadLetterQueue.process(Function<DeadLetter<? extends E>, CompletableFuture<EnqueueDecision<E>>> processingTask, @Nullable ProcessingContext context) Process a single sequence of enqueueddead letterswith the givenprocessingTask. -
Uses of EnqueueDecision in org.axonframework.messaging.eventhandling.deadletter.jpa
Method parameters in org.axonframework.messaging.eventhandling.deadletter.jpa with type arguments of type EnqueueDecisionModifier and TypeMethodDescriptionJpaSequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) Process a single sequence of enqueueddead letterswith the givenprocessingTask.JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context)