Package | Description |
---|---|
org.axonframework.axonserver.connector.processor | |
org.axonframework.config | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.pooled |
Modifier and Type | Method and Description |
---|---|
protected Supplier<io.axoniq.axonserver.grpc.control.EventProcessorInfo> |
EventProcessorControlService.infoSupplier(EventProcessor processor)
Constructs an
EventProcessorInfo for the given processor . |
Constructor and Description |
---|
AxonProcessorInstructionHandler(EventProcessor processor,
String name) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Component<EventProcessor>> |
EventProcessingModule.eventProcessors |
Modifier and Type | Method and Description |
---|---|
<T extends EventProcessor> |
SagaConfiguration.eventProcessor()
Gets the
EventProcessor responsible for delivering events to this Saga. |
default <T extends EventProcessor> |
EventProcessingConfiguration.eventProcessor(String name)
Obtains an
EventProcessor through the given name . |
default <T extends EventProcessor> |
EventProcessingConfiguration.eventProcessor(String name,
Class<T> expectedType)
|
<T extends EventProcessor> |
EventProcessingModule.eventProcessorByProcessingGroup(String processingGroup) |
<T extends EventProcessor> |
EventProcessingConfiguration.eventProcessorByProcessingGroup(String processingGroup)
Obtains an
EventProcessor by it's processingGroup . |
default <T extends EventProcessor> |
EventProcessingConfiguration.eventProcessorByProcessingGroup(String processingGroup,
Class<T> expectedType)
|
default <T extends EventProcessor> |
EventProcessingConfiguration.sagaEventProcessor(Class<?> sagaType)
Obtains an Saga
EventProcessor implementation for the given sagaType . |
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 | Method and Description |
---|---|
Map<String,EventProcessor> |
EventProcessingModule.eventProcessors() |
Map<String,EventProcessor> |
EventProcessingConfiguration.eventProcessors()
Obtains all registered
EventProcessor s. |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamingEventProcessor
An
EventProcessor which processes an event stream in segments. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventProcessor
Abstract implementation of an
EventProcessor . |
class |
SubscribingEventProcessor
Event processor implementation that
subscribes to the EventBus for
events. |
class |
TrackingEventProcessor
EventProcessor implementation that tracks events from a
StreamableMessageSource . |
Modifier and Type | Class and Description |
---|---|
class |
PooledStreamingEventProcessor
A
StreamingEventProcessor implementation which pools its resources to enhance processing speed. |
Copyright © 2010–2024. All rights reserved.