Uses of Interface
org.axonframework.messaging.deadletter.DeadLetter
Packages that use DeadLetter
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 DeadLetter in org.axonframework.messaging.deadletter
Classes in org.axonframework.messaging.deadletter that implement DeadLetterModifier and TypeClassDescriptionclassGenericDeadLetter<M extends Message>Generic implementation of thedead letterallowing any type ofMessageto be dead lettered.Fields in org.axonframework.messaging.deadletter with type parameters of type DeadLetterModifier and TypeFieldDescriptionstatic final Context.ResourceKey<DeadLetter<?>> DeadLetter.RESOURCE_KEYMethods in org.axonframework.messaging.deadletter that return DeadLetterModifier and TypeMethodDescriptionDeadLetter.markTouched()Construct a copy of thisDeadLetter, replacing thelastTouched()with the current time.GenericDeadLetter.markTouched()default DeadLetter<M> DeadLetter.withDiagnostics(UnaryOperator<Metadata> diagnosticsBuilder) Construct a copy of thisDeadLetter, replacing thediagnostics()with the result of the givendiagnosticsBuilder.DeadLetter.withDiagnostics(Metadata diagnostics) default DeadLetter<? extends M> EnqueueDecision.withDiagnostics(DeadLetter<? extends M> letter) GenericDeadLetter.withDiagnostics(Metadata diagnostics) DeadLetter<? extends M> ShouldEnqueue.withDiagnostics(DeadLetter<? extends M> letter) Methods in org.axonframework.messaging.deadletter that return types with arguments of type DeadLetterModifier and TypeMethodDescription@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 alldead lettersequences 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 thedead lettersfor the givensequenceIdentifierin insert order.static Optional<DeadLetter<?>> DeadLetter.fromContext(Context context) Returns anOptionalof {DeadLetter}, returning the resource keyed under theRESOURCE_KEYin the givencontext.Methods in org.axonframework.messaging.deadletter with parameters of type DeadLetterModifier and TypeMethodDescriptionEnqueuePolicy.decide(DeadLetter<? extends M> letter, Throwable cause) InMemorySequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter, @Nullable ProcessingContext context) SequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter, @Nullable ProcessingContext context) Enqueues adead lettercontaining an implementation ofMto this queue.InMemorySequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter, @Nullable ProcessingContext context) SequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter, @Nullable ProcessingContext context) Evict the givenletterfrom this queue.InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) Reenters the givenletter, updating the contents with theletterUpdater.default DeadLetter<? extends M> EnqueueDecision.withDiagnostics(DeadLetter<? extends M> letter) DeadLetter<? extends M> ShouldEnqueue.withDiagnostics(DeadLetter<? extends M> letter) Method parameters in org.axonframework.messaging.deadletter with type arguments of type DeadLetterModifier and TypeMethodDescriptionstatic <M extends Message>
ShouldEnqueue<M> Decisions.enqueue(Throwable enqueueCause, Function<DeadLetter<? extends M>, Metadata> diagnosticsBuilder) Construct aShouldEnqueuedefining that adead lettershould be enqueued because of the givenenqueueCause.default CompletableFuture<Boolean> SequencedDeadLetterQueue.enqueueIfPresent(Object sequenceIdentifier, Supplier<DeadLetter<? extends M>> letterBuilder, @Nullable ProcessingContext context) Enqueue the result of the givenletterBuilderonly if there already are otherdead letterswith the samesequenceIdentifierpresent in this queue.InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) SequencedDeadLetterProcessor.process(Predicate<DeadLetter<? extends M>> sequenceFilter) Process a sequence ofdead lettersmatching the givensequenceFilter.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.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.static <M extends Message>
ShouldEnqueue<M> Decisions.requeue(Throwable requeueCause, Function<DeadLetter<? extends M>, Metadata> diagnosticsBuilder) Construct aShouldEnqueuedefining that adead lettershould be requeued because of the givenrequeueCause.InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) Reenters the givenletter, updating the contents with theletterUpdater.Constructor parameters in org.axonframework.messaging.deadletter with type arguments of type DeadLetterModifierConstructorDescriptionShouldEnqueue(Throwable enqueueCause, Function<DeadLetter<? extends M>, Metadata> diagnosticsBuilder) Constructs a defaultEnqueueDecisionto enqueue using the givenenqueueCauseas theShouldEnqueue.enqueueCause(). -
Uses of DeadLetter in org.axonframework.messaging.eventhandling.deadletter
Methods in org.axonframework.messaging.eventhandling.deadletter that return types with arguments of type DeadLetterModifier and TypeMethodDescriptionCompletableFuture<Iterable<Iterable<DeadLetter<? extends M>>>> CachingSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context) CompletableFuture<Iterable<DeadLetter<? extends M>>> CachingSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context) Methods in org.axonframework.messaging.eventhandling.deadletter with parameters of type DeadLetterModifier and TypeMethodDescriptionCachingSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter, @Nullable ProcessingContext context) CachingSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter, @Nullable ProcessingContext context) CachingSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) Method parameters in org.axonframework.messaging.eventhandling.deadletter with type arguments of type DeadLetterModifier and TypeMethodDescriptionCachingSequencedDeadLetterQueue.enqueueIfPresent(Object sequenceIdentifier, Supplier<DeadLetter<? extends M>> letterBuilder, @Nullable ProcessingContext context) CachingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) CachingSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) DeadLetteringEventHandlingComponent.process(Predicate<DeadLetter<? extends EventMessage>> sequenceFilter) CachingSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) -
Uses of DeadLetter in org.axonframework.messaging.eventhandling.deadletter.jdbc
Classes in org.axonframework.messaging.eventhandling.deadletter.jdbc that implement DeadLetterModifier and TypeClassDescriptionclassJdbcDeadLetter<E extends EventMessage>ADeadLetterthat was saved to a JDBC-backed database and reconstructed from it.Methods in org.axonframework.messaging.eventhandling.deadletter.jdbc that return DeadLetterModifier and TypeMethodDescriptionJdbcDeadLetter.markTouched()JdbcDeadLetter.withDiagnostics(Metadata diagnostics) Methods in org.axonframework.messaging.eventhandling.deadletter.jdbc that return types with arguments of type DeadLetterModifier and TypeMethodDescription@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 org.axonframework.messaging.eventhandling.deadletter.jdbc with parameters of type DeadLetterModifier and TypeMethodDescriptionJdbcSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends E> letter, @Nullable ProcessingContext context) DeadLetterStatementFactory.enqueueStatement(Connection connection, String processingGroup, String sequenceIdentifier, DeadLetter<? extends E> letter, long sequenceIndex) Constructs thePreparedStatementused for theJdbcSequencedDeadLetterQueue.enqueue(Object, DeadLetter, ProcessingContext)operation.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) JdbcSequencedDeadLetterQueue.requeue(DeadLetter<? extends E> letter, UnaryOperator<DeadLetter<? extends E>> letterUpdater, @Nullable ProcessingContext context) Method parameters in org.axonframework.messaging.eventhandling.deadletter.jdbc with type arguments of type DeadLetterModifier 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) @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.JdbcSequencedDeadLetterQueue.requeue(DeadLetter<? extends E> letter, UnaryOperator<DeadLetter<? extends E>> letterUpdater, @Nullable ProcessingContext context) -
Uses of DeadLetter in org.axonframework.messaging.eventhandling.deadletter.jpa
Classes in org.axonframework.messaging.eventhandling.deadletter.jpa that implement DeadLetterModifier and TypeClassDescriptionclassJpaDeadLetter<M extends EventMessage>ADeadLetterthat was saved to the database and reconstructed from it.Methods in org.axonframework.messaging.eventhandling.deadletter.jpa that return DeadLetterModifier and TypeMethodDescriptionJpaDeadLetter.markTouched()JpaDeadLetter.withDiagnostics(Metadata diagnostics) Methods in org.axonframework.messaging.eventhandling.deadletter.jpa that return types with arguments of type DeadLetterModifier and TypeMethodDescriptionCompletableFuture<Iterable<Iterable<DeadLetter<? extends M>>>> JpaSequencedDeadLetterQueue.deadLetters(@Nullable ProcessingContext context) CompletableFuture<Iterable<DeadLetter<? extends M>>> JpaSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier, @Nullable ProcessingContext context) Methods in org.axonframework.messaging.eventhandling.deadletter.jpa with parameters of type DeadLetterModifier and TypeMethodDescriptionJpaSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier, DeadLetter<? extends M> letter, @Nullable ProcessingContext context) JpaSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter, @Nullable ProcessingContext context) JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context) Method parameters in org.axonframework.messaging.eventhandling.deadletter.jpa with type arguments of type DeadLetterModifier 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) JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter, Function<DeadLetter<? extends M>, CompletableFuture<EnqueueDecision<M>>> processingTask, @Nullable ProcessingContext context) JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter, UnaryOperator<DeadLetter<? extends M>> letterUpdater, @Nullable ProcessingContext context)