Uses of Class
org.axonframework.eventhandling.pooled.PooledStreamingEventProcessor.Builder

Packages that use PooledStreamingEventProcessor.Builder

Package	Description
org.axonframework.eventhandling.pooled

Uses of PooledStreamingEventProcessor.Builder in org.axonframework.eventhandling.pooled

Methods in org.axonframework.eventhandling.pooled that return PooledStreamingEventProcessor.Builder

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.enableCoordinatorClaimExtension() Enables the Coordinator to extend the claims of its WorkPackages.
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 TrackingTokens.
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.maxClaimedSegments(int maxClaimedSegments) Sets the maximum number of segments this instance may claim.
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.maxSegmentProvider(MaxSegmentProvider maxSegmentProvider) Defines the maximum number of segment this StreamingEventProcessor may claim per instance.
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(EventProcessorSpanFactory spanFactory)
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.spanFactory(SpanFactory spanFactory) Deprecated.
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 EventMessages.
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.workerExecutor(Function<String,ScheduledExecutorService> workerExecutorBuilder) Specifies a builder to construct a ScheduledExecutorService to be provided to the WorkPackages created by this PooledStreamingEventProcessor.
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.workerExecutor(ScheduledExecutorService workerExecutor) Specifies the ScheduledExecutorService to be provided to the WorkPackages created by this PooledStreamingEventProcessor.
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.workerExecutorService(ScheduledExecutorService workerExecutor) Deprecated. in favor of workerExecutor(ScheduledExecutorService)

Constructors in org.axonframework.eventhandling.pooled with parameters of type PooledStreamingEventProcessor.Builder

Constructor and Description
PooledStreamingEventProcessor(PooledStreamingEventProcessor.Builder builder) Instantiate a PooledStreamingEventProcessor based on the fields contained in the PooledStreamingEventProcessor.Builder.