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.deadletter | |
org.axonframework.eventhandling.pooled | |
org.axonframework.modelling.saga |
Modifier and Type | Method and Description |
---|---|
EventProcessor |
EventProcessingConfigurer.EventProcessorBuilder.build(String name,
Configuration configuration,
EventHandlerInvoker eventHandlerInvoker)
|
protected EventProcessor |
EventProcessingModule.pooledStreamingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
Configuration config,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)
Default
PooledStreamingEventProcessor configuration based on this configure module. |
protected EventProcessor |
EventProcessingModule.subscribingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
SubscribableMessageSource<? extends EventMessage<?>> messageSource)
Default
SubscribingEventProcessor configuration based on this configure module. |
protected EventProcessor |
EventProcessingModule.trackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
TrackingEventProcessorConfiguration config,
StreamableMessageSource<TrackedEventMessage<?>> source)
Default
TrackingEventProcessor configuration based on this configure module. |
Modifier and Type | Class and Description |
---|---|
class |
MultiEventHandlerInvoker
Implementation of
EventHandlerInvoker with capabilities to invoke several different invokers. |
class |
SimpleEventHandlerInvoker
Implementation of an
EventHandlerInvoker that forwards events to a list of registered EventMessageHandler . |
Modifier and Type | Method and Description |
---|---|
EventHandlerInvoker |
AbstractEventProcessor.eventHandlerInvoker()
Returns the invoker assigned to this processor.
|
Modifier and Type | Method and Description |
---|---|
List<EventHandlerInvoker> |
MultiEventHandlerInvoker.delegates() |
Modifier and Type | Method and Description |
---|---|
TrackingEventProcessor.Builder |
TrackingEventProcessor.Builder.eventHandlerInvoker(EventHandlerInvoker eventHandlerInvoker) |
SubscribingEventProcessor.Builder |
SubscribingEventProcessor.Builder.eventHandlerInvoker(EventHandlerInvoker eventHandlerInvoker) |
AbstractEventProcessor.Builder |
AbstractEventProcessor.Builder.eventHandlerInvoker(EventHandlerInvoker eventHandlerInvoker)
Sets the
EventHandlerInvoker which will handle all the individual EventMessage s. |
Constructor and Description |
---|
MultiEventHandlerInvoker(EventHandlerInvoker... delegates)
Initializes multi invoker with different invokers.
|
Constructor and Description |
---|
MultiEventHandlerInvoker(List<EventHandlerInvoker> delegates)
Initializes multi invoker with different invokers.
|
Modifier and Type | Class and Description |
---|---|
class |
DeadLetteringEventHandlerInvoker
Implementation of an
EventHandlerInvoker utilizing a SequencedDeadLetterQueue to enqueue
events for which handling failed. |
Modifier and Type | Method and Description |
---|---|
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.eventHandlerInvoker(EventHandlerInvoker eventHandlerInvoker) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSagaManager<T>
Abstract implementation of the SagaManager interface that provides basic functionality required by most SagaManager
implementations.
|
class |
AnnotatedSagaManager<T>
Implementation of the SagaManager that uses annotations on the Sagas to describe the lifecycle management.
|
Copyright © 2010–2024. All rights reserved.