| Package | Description |
|---|---|
| org.axonframework.config | |
| org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus. |
| org.axonframework.eventhandling.async |
| Modifier and Type | Field and Description |
|---|---|
protected Map<String,Component<SequencingPolicy<? super EventMessage<?>>>> |
EventProcessingModule.sequencingPolicies |
| Modifier and Type | Method and Description |
|---|---|
SequencingPolicy<? super EventMessage<?>> |
EventProcessingModule.sequencingPolicy(String processingGroup) |
SequencingPolicy<? super EventMessage<?>> |
EventProcessingConfiguration.sequencingPolicy(String processingGroup)
Returns the
SequencingPolicy tied to the given processingGroup. |
| Modifier and Type | Method and Description |
|---|---|
EventProcessingConfigurer |
EventProcessingModule.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
Registers the
SequencingPolicy created by given policyBuilder to the processing groups for which
no explicit policy is defined (using EventProcessingConfigurer.registerSequencingPolicy(String, Function)). |
EventProcessingConfigurer |
EventProcessingModule.registerSequencingPolicy(String processingGroup,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerSequencingPolicy(String processingGroup,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
Registers the
SequencingPolicy created by the given policyBuilder to the processing group with
given processingGroup. |
| Modifier and Type | Method and Description |
|---|---|
SequencingPolicy<? super EventMessage<?>> |
SimpleEventHandlerInvoker.getSequencingPolicy()
Return the
SequencingPolicy as configured for this EventHandlerInvoker. |
| Modifier and Type | Method and Description |
|---|---|
B |
SimpleEventHandlerInvoker.Builder.sequencingPolicy(SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Sets the
SequencingPolicy in charge of deciding whether a given event should be handled (through
EventHandlerInvoker.handle(EventMessage, Segment)) by the given Segment. |
| Modifier and Type | Class and Description |
|---|---|
class |
FullConcurrencyPolicy
SequencingPolicy that does not enforce any sequencing requirements on event processing.
|
class |
PropertySequencingPolicy<T,K>
A
SequencingPolicy implementation that extracts the sequence identifier from the event message payload based
on a given property or property extractor. |
class |
SequentialPerAggregatePolicy
Concurrency policy that requires sequential processing of events raised by the same aggregate.
|
class |
SequentialPolicy
SequencingPolicy that requires sequential handling of all events delivered to an event handler.
|
| Modifier and Type | Method and Description |
|---|---|
PropertySequencingPolicy.Builder<T,K> |
PropertySequencingPolicy.Builder.fallbackSequencingPolicy(SequencingPolicy<EventMessage> fallbackSequencingPolicy)
Defines the fallback sequencing policy, the sequencing policy which is applied if the event message payload
is not of a supported type.
|
| Constructor and Description |
|---|
AsynchronousEventProcessingStrategy(Executor executor,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Initializes a new
AsynchronousEventProcessingStrategy that uses the given executor to execute
event processing tasks and sequencingPolicy that determines if an event may be processed in sequence or
in parallel. |
Copyright © 2010–2023. All rights reserved.