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	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(ScheduledExecutorService coordinatorExecutor)	Specifies the ScheduledExecutorService used by the coordinator of this PooledStreamingEventProcessor.
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.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. the EventStore) which this EventProcessor will track.
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(ScheduledExecutorService workerExecutor)	Specifies the ScheduledExecutorService to be provided to the WorkPackages created by this PooledStreamingEventProcessor.
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.workerExecutorService(ScheduledExecutorService workerExecutor)	Deprecated. in favor of workerExecutor(ScheduledExecutorService)

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

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