public class DeadLetterQueueProviderConfigurerModule extends Object implements ConfigurerModule
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.
| Constructor and Description |
|---|
DeadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties,
Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)
Construct a
DeadLetterQueueProviderConfigurerModule, using the given eventProcessorProperties to
decide which processing groups receive the SequencedDeadLetterQueue from the given
deadLetterQueueProvider. |
| Modifier and Type | Method and Description |
|---|---|
void |
configureModule(Configurer configurer)
Configure this module to the given global
Configurer. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitorderpublic DeadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties, Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)
DeadLetterQueueProviderConfigurerModule, using the given eventProcessorProperties to
decide which processing groups receive the SequencedDeadLetterQueue from the given
deadLetterQueueProvider.eventProcessorProperties - The properties dictating for which processing groups the dead-letter queue is
enabled.deadLetterQueueProvider - The function providing the SequencedDeadLetterQueue.public void configureModule(@Nonnull Configurer configurer)
ConfigurerModuleConfigurer.configureModule in interface ConfigurerModuleconfigurer - a Configurer instance to configure this module withCopyright © 2010–2025. All rights reserved.