| 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 | |
| org.axonframework.kafka.eventhandling |
| Modifier and Type | Method and Description |
|---|---|
EventHandlingConfiguration |
EventHandlingConfiguration.configureSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicyBuilder)
Configures the default Sequencing Policy to use when invoking event handlers asynchronously.
|
EventHandlingConfiguration |
EventHandlingConfiguration.configureSequencingPolicy(String processingGroup,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicyBuilder)
Configures the Sequencing Policy to use for handler assigned to the given
processingGroup, when invoking
these handlers asynchronously. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
Registers the sequencing policy created by given
policyBuilder to the processing groups for which no
explicit policy is defined (using EventHandlingConfiguration.registerSequencingPolicy(String, Function)). |
EventHandlingConfiguration |
EventHandlingConfiguration.registerSequencingPolicy(String name,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)
Registers the sequencing policy created by given
policyBuilder to the processing group with given
name. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Deprecated.
|
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Deprecated.
|
EventHandlingConfiguration |
EventHandlingConfiguration.usingTrackingProcessors(Function<Configuration,TrackingEventProcessorConfiguration> config,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
SequencingPolicy<? super EventMessage<?>> |
SimpleEventHandlerInvoker.getSequencingPolicy() |
| Constructor and Description |
|---|
SimpleEventHandlerInvoker(List<?> eventListeners,
ListenerInvocationErrorHandler listenerInvocationErrorHandler,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Initialize the EventHandlerInvoker to invoke the given
eventListeners, using the given
listenerInvocationErrorHandler when an error occurs invoking these handlers and the given
sequencingPolicy to describe the expected sequencing of event messages |
SimpleEventHandlerInvoker(List<?> eventListeners,
ParameterResolverFactory parameterResolverFactory,
ListenerInvocationErrorHandler listenerInvocationErrorHandler,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Initializes a
SimpleEventHandlerInvoker containing the given list of eventListeners. |
| Modifier and Type | Class and Description |
|---|---|
class |
FullConcurrencyPolicy
SequencingPolicy that does not enforce any sequencing requirements on event processing.
|
class |
SequentialPerAggregatePolicy
Concurrency policy that requires sequential processing of events raised by the same aggregate.
|
class |
SequentialPolicy
SequencingPolicy that requires serialized handling of all events delivered to an event handler.
|
| 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. |
| Constructor and Description |
|---|
DefaultKafkaMessageConverter(Serializer serializer,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy,
BiFunction<String,Object,org.apache.kafka.common.header.internals.RecordHeader> headerValueMapper)
Initializes the KafkaMessageConverter with the given
serializer, sequencingPolicy and
objectMapper. |
Copyright © 2010–2018. All rights reserved.