Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
Modifier and Type | Method and Description |
---|---|
SagaConfiguration<S> |
SagaConfiguration.configureTrackingProcessor(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfiguration)
Registers the
TrackingEventProcessorConfiguration to use when building the processor for this Saga type. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Registers a TrackingProcessor with the given
name , reading from the given source and using the
given processorConfiguration . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Registers a TrackingProcessor with the given
name , reading from the Event Bus (or Store) from the main
configuration and using the given processorConfiguration . |
EventHandlingConfiguration |
EventHandlingConfiguration.usingTrackingProcessors(Function<Configuration,TrackingEventProcessorConfiguration> config,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Configure the use of Tracking Event Processors, instead of the default Subscribing ones.
|
Modifier and Type | Method and Description |
---|---|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andBatchSize(int batchSize) |
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andInitialSegmentsCount(int segmentsSize) |
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andThreadFactory(Function<String,ThreadFactory> threadFactory)
Sets the ThreadFactory to use to create the threads to process events on.
|
static TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.forParallelProcessing(int threadCount)
Initialize a configuration instance with the given
threadCount . |
static TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.forSingleThreadedProcessing()
Initialize a configuration with single threaded processing.
|
Constructor and Description |
---|
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager,
MessageMonitor<? super EventMessage<?>> messageMonitor,
RollbackConfiguration rollbackConfiguration,
ErrorHandler errorHandler,
TrackingEventProcessorConfiguration config)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
Copyright © 2010–2017. All rights reserved.