Class DeadLetterQueueProviderConfigurerModule
java.lang.Object
org.axonframework.springboot.util.DeadLetterQueueProviderConfigurerModule
- All Implemented Interfaces:
ConfigurerModule
A
ConfigurerModule implementation dedicated towards registering a SequencedDeadLetterQueue provider
with the EventProcessingConfigurer.
Does so through invoking the
EventProcessingConfigurer.registerDeadLetterQueueProvider(Function) operation,
utilizing the given deadLetterQueueProvider. Only processing groups for which the dead-letter queue is
enabled will receive the provided dead-letter queue.
- Since:
- 4.8.0
- Author:
- Gerard Klijs, Steven van Beelen
-
Constructor Summary
ConstructorsConstructorDescriptionDeadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties, Function<String, Function<Configuration, SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider) Construct aDeadLetterQueueProviderConfigurerModule, using the giveneventProcessorPropertiesto decide which processing groups receive theSequencedDeadLetterQueuefrom the givendeadLetterQueueProvider. -
Method Summary
Modifier and TypeMethodDescriptionvoidconfigureModule(Configurer configurer) Configure this module to the given globalConfigurer.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.axonframework.config.ConfigurerModule
order
-
Constructor Details
-
DeadLetterQueueProviderConfigurerModule
public DeadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties, Function<String, Function<Configuration, SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider) Construct aDeadLetterQueueProviderConfigurerModule, using the giveneventProcessorPropertiesto decide which processing groups receive theSequencedDeadLetterQueuefrom the givendeadLetterQueueProvider.- Parameters:
eventProcessorProperties- The properties dictating for which processing groups the dead-letter queue isenabled.deadLetterQueueProvider- The function providing theSequencedDeadLetterQueue.
-
-
Method Details
-
configureModule
Description copied from interface:ConfigurerModuleConfigure this module to the given globalConfigurer.- Specified by:
configureModulein interfaceConfigurerModule- Parameters:
configurer- aConfigurerinstance to configure this module with
-