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 | Field and Description |
---|---|
protected Map<String,Component<TrackingEventProcessorConfiguration>> |
EventProcessingModule.tepConfigs |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andAutoStart(boolean autoStart)
Whether to automatically start the processor when event processing is initialized.
|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andBatchSize(int batchSize)
Set the maximum number of events that may be processed in a single transaction.
|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andEventAvailabilityTimeout(long interval,
TimeUnit unit)
Set the duration where a Tracking Processor will wait for the availability of Events, in each cycle, before
extending the claim on the tokens it owns.
|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andEventTrackerStatusChangeListener(EventTrackerStatusChangeListener eventTrackerStatusChangeListener)
Sets the
EventTrackerStatusChangeListener which will be called on EventTrackerStatus changes. |
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andInitialSegmentsCount(int segmentsSize)
Sets the initial number of segments for asynchronous processing.
|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andInitialTrackingToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenBuilder)
Sets the builder to use to create the initial
TrackingToken . |
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andThreadFactory(Function<String,ThreadFactory> threadFactory)
Sets the
ThreadFactory to use to create the Threads to process events on. |
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andTokenClaimInterval(long tokenClaimInterval,
TimeUnit timeUnit)
Sets the time to wait after a failed attempt to claim any token, before making another attempt.
|
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andWorkerTerminationTimeout(long workerTerminationTimeoutInMilliseconds)
Deprecated.
Use
andWorkerTerminationTimeout(long, TimeUnit) instead. |
TrackingEventProcessorConfiguration |
TrackingEventProcessorConfiguration.andWorkerTerminationTimeout(long workerTerminationTimeout,
TimeUnit timeUnit)
Sets the shutdown timeout to terminate active workers.
|
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.
|
Modifier and Type | Method and Description |
---|---|
TrackingEventProcessor.Builder |
TrackingEventProcessor.Builder.trackingEventProcessorConfiguration(TrackingEventProcessorConfiguration trackingEventProcessorConfiguration)
Sets the
TrackingEventProcessorConfiguration containing the fine grained configuration options for a
TrackingEventProcessor . |
Copyright © 2010–2024. All rights reserved.