Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.eventhandling.deadletter |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Component<EnqueuePolicy<EventMessage<?>>>> |
EventProcessingModule.deadLetterPolicies |
Modifier and Type | Method and Description |
---|---|
Optional<EnqueuePolicy<EventMessage<?>>> |
EventProcessingModule.deadLetterPolicy(String processingGroup) |
default Optional<EnqueuePolicy<EventMessage<?>>> |
EventProcessingConfiguration.deadLetterPolicy(String processingGroup)
|
Modifier and Type | Method and Description |
---|---|
EventProcessingConfigurer |
EventProcessingModule.registerDeadLetterPolicy(String processingGroup,
Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerDeadLetterPolicy(String processingGroup,
Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)
Register a default
dead letter policy for any processing group using a
dead letter queue . |
Modifier and Type | Method and Description |
---|---|
DeadLetteringEventHandlerInvoker.Builder |
DeadLetteringEventHandlerInvoker.Builder.enqueuePolicy(EnqueuePolicy<EventMessage<?>> enqueuePolicy)
Sets the
EnqueuePolicy this EventHandlerInvoker uses to decide whether a
dead letter should be added to the SequencedDeadLetterQueue . |
Copyright © 2010–2023. All rights reserved.