Package | Description |
---|---|
org.axonframework.axonserver.connector.event.axon | |
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 | Method and Description |
---|---|
SequencingPolicy<EventMessage<?>> |
PersistentStreamSequencingPolicyProvider.apply(Configuration configuration) |
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–2024. All rights reserved.