Package | Description |
---|---|
org.axonframework.eventhandling.pooled |
Modifier and Type | Method and Description |
---|---|
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.batchSize(int batchSize)
Specifies the number of events to be processed inside a single transaction.
|
static PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.builder()
Instantiate a Builder to be able to create a
PooledStreamingEventProcessor . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.claimExtensionThreshold(long claimExtensionThreshold)
Specifies a time in milliseconds the work packages of this processor should extend the claim on a
TrackingToken . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.clock(Clock clock)
Defines the
Clock used for time dependent operation by this EventProcessor . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.coordinatorExecutor(Function<String,ScheduledExecutorService> coordinatorExecutorBuilder)
Specifies a builder to construct a
ScheduledExecutorService used by the coordinator of this PooledStreamingEventProcessor . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.coordinatorExecutor(ScheduledExecutorService coordinatorExecutor)
Specifies the
ScheduledExecutorService used by the coordinator of this PooledStreamingEventProcessor . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.errorHandler(ErrorHandler errorHandler) |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.eventHandlerInvoker(EventHandlerInvoker eventHandlerInvoker) |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.initialSegmentCount(int initialSegmentCount)
Sets the initial segment count used to create segments on start up.
|
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.initialToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialToken)
Specifies the
Function used to generate the initial TrackingToken s. |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.maxClaimedSegments(int maxClaimedSegments)
Defines the maximum number of segment this
StreamingEventProcessor may claim. |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource)
Sets the
StreamableMessageSource (e.g. |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.name(String name) |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.rollbackConfiguration(RollbackConfiguration rollbackConfiguration) |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.spanFactory(SpanFactory spanFactory) |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.tokenClaimInterval(long tokenClaimInterval)
Specifies the time in milliseconds the processor's coordinator should wait after a failed attempt to claim
any segments for processing.
|
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.tokenStore(TokenStore tokenStore)
Sets the
TokenStore used to store and fetch event tokens that enable this EventProcessor to
track its progress. |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.transactionManager(TransactionManager transactionManager)
Sets the
TransactionManager used when processing EventMessage s. |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.workerExecutor(Function<String,ScheduledExecutorService> workerExecutorBuilder)
Specifies a builder to construct a
ScheduledExecutorService to be provided to the WorkPackage s created by this PooledStreamingEventProcessor . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.workerExecutor(ScheduledExecutorService workerExecutor)
Specifies the
ScheduledExecutorService to be provided to the WorkPackage s created by this
PooledStreamingEventProcessor . |
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.workerExecutorService(ScheduledExecutorService workerExecutor)
Deprecated.
in favor of
workerExecutor(ScheduledExecutorService) |
Constructor and Description |
---|
PooledStreamingEventProcessor(PooledStreamingEventProcessor.Builder builder)
Instantiate a
PooledStreamingEventProcessor based on the fields contained in the PooledStreamingEventProcessor.Builder . |
Copyright © 2010–2023. All rights reserved.