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.