Uses of Interface
io.axoniq.framework.messaging.deadletter.SequencedDeadLetterQueue
Packages that use SequencedDeadLetterQueue
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.
Integrates dead-letter queue handling with multi-tenant event processing.
-
Uses of SequencedDeadLetterQueue in io.axoniq.framework.messaging.deadletter
Classes in io.axoniq.framework.messaging.deadletter that implement SequencedDeadLetterQueueModifier and TypeClassDescriptionclassInMemorySequencedDeadLetterQueue<M extends Message>In-memory implementation of theSequencedDeadLetterQueue. -
Uses of SequencedDeadLetterQueue in io.axoniq.framework.messaging.eventhandling.deadletter
Classes in io.axoniq.framework.messaging.eventhandling.deadletter that implement SequencedDeadLetterQueueModifier and TypeClassDescriptionclassCachingSequencedDeadLetterQueue<M extends Message>A decorator forSequencedDeadLetterQueuethat adds per-segment caching of sequence identifiers to optimizeCachingSequencedDeadLetterQueue.contains(Object, ProcessingContext)lookups.Methods in io.axoniq.framework.messaging.eventhandling.deadletter that return SequencedDeadLetterQueueModifier and TypeMethodDescriptionSequencedDeadLetterQueueFactory.create(String processingGroup, Configuration configuration) Creates aSequencedDeadLetterQueuefor the givenprocessingGroup.Constructors in io.axoniq.framework.messaging.eventhandling.deadletter with parameters of type SequencedDeadLetterQueueModifierConstructorDescriptionConstructs a caching decorator with the given delegate and default cache settings.CachingSequencedDeadLetterQueue(SequencedDeadLetterQueue<M> delegate, int cacheMaxSize) Constructs a caching decorator with the given delegate and cache max size.DeadLetteringEventHandlingComponent(EventHandlingComponent delegate, SequencedDeadLetterQueue<EventMessage> queue, EnqueuePolicy<EventMessage> enqueuePolicy, UnitOfWorkFactory unitOfWorkFactory, boolean allowReset) Instantiate aDeadLetteringEventHandlingComponentwith the givendelegate,queue, customEnqueuePolicy, reset behavior, andunitOfWorkFactory. -
Uses of SequencedDeadLetterQueue in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc
Classes in io.axoniq.framework.messaging.eventhandling.deadletter.jdbc that implement SequencedDeadLetterQueueModifier and TypeClassDescriptionclassJdbcSequencedDeadLetterQueue<E extends EventMessage>A JDBC-based implementation of theSequencedDeadLetterQueue, used for storing dead letters containingevent messagesdurably. -
Uses of SequencedDeadLetterQueue in io.axoniq.framework.messaging.eventhandling.deadletter.jpa
Classes in io.axoniq.framework.messaging.eventhandling.deadletter.jpa that implement SequencedDeadLetterQueueModifier and TypeClassDescriptionclassJpaSequencedDeadLetterQueue<M extends EventMessage>JPA-backed implementation of theSequencedDeadLetterQueue, used for storing dead letters containingEventMessagesdurably as aDeadLetterEntry. -
Uses of SequencedDeadLetterQueue in io.axoniq.framework.messaging.multitenancy.deadletter
Classes in io.axoniq.framework.messaging.multitenancy.deadletter that implement SequencedDeadLetterQueueModifier and TypeClassDescriptionclassRoutes dead-letter queue operations to a queue dedicated to the tenant carried by the processing context.Methods in io.axoniq.framework.messaging.multitenancy.deadletter that return SequencedDeadLetterQueueModifier and TypeMethodDescriptionTenantAwareSequencedDeadLetterQueueFactory.create(TenantDescriptor tenant, String processorName, Configuration configuration) Creates the concrete dead-letter queue for the giventenantandprocessorName.TenantRoutingSequencedDeadLetterQueueRegistry.queueFor(String processorName, Configuration configuration, TenantAwareSequencedDeadLetterQueueFactory factory, TenantDescriptor tenant) Returns the queue of the given tenant for the dead-letter queue identified by the supplied processing group, configuration, and delegate factory.