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, wait
order
public 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)
ConfigurerModule
Configurer
.configureModule
in interface ConfigurerModule
configurer
- a Configurer
instance to configure this module withCopyright © 2010–2024. All rights reserved.