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 |
---|---|
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.