Package org.axonframework.messaging.eventhandling.deadletter

Interface SequencedDeadLetterQueueFactory

Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface SequencedDeadLetterQueueFactory
Factory that creates a SequencedDeadLetterQueue for a given processing group.

Implementations provide the backing store for dead-lettered events. The factory is invoked once per event handling component when DLQ support is enabled, allowing each component within a processor to have its own queue.

Example: 


 SequencedDeadLetterQueueFactory myFactory = (processingGroup, configuration) ->
     new MySequencedDeadLetterQueue(processingGroup, storage);
Since:
5.1.0
Author:
Mateusz Nowak

  • Method Details

    • create

      SequencedDeadLetterQueue<EventMessage> create(String processingGroup, Configuration configuration)
      Creates a SequencedDeadLetterQueue for the given processingGroup.

      The processingGroup is a component-scoped identifier that uniquely identifies the dead letter queue within its event processor. A single processor may contain multiple event handling components, each with its own DLQ. The name follows the pattern "DeadLetterQueue[processorName][componentName]", for example "DeadLetterQueue[myProcessor][myComponent]" for a component named "myComponent" within a processor named "myProcessor".

      Implementations should use this value as-is when scoping dead letters in their backing store (e.g., as the processingGroup column in a database table).

      Parameters:
      processingGroup - The component-scoped identifier used to scope dead letters to a single event handling component's queue, e.g. "DeadLetterQueue[myProcessor][myComponent]".
      configuration - The Configuration providing access to framework components needed to build the queue (e.g., entity managers, converters). May be ignored when all dependencies are already wired externally (e.g., in a Spring context via bean injection).
      Returns:
      A SequencedDeadLetterQueue scoped to the given processing group.