Uses of Class
org.axonframework.messaging.eventhandling.processing.streaming.pooled.PooledStreamingEventProcessorConfiguration

Packages that use PooledStreamingEventProcessorConfiguration

Package	Description
org.axonframework.extension.spring.config	Part of the Axon Extension module.
org.axonframework.messaging.eventhandling.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.pooled	Part of the Axon Messaging module.

Uses of PooledStreamingEventProcessorConfiguration in org.axonframework.extension.spring.config

Methods in org.axonframework.extension.spring.config that return types with arguments of type PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
static EventProcessorDefinition.SelectorStep<PooledStreamingEventProcessorConfiguration>	EventProcessorDefinition.pooledStreaming(String name)	Creates a new processor definition for a pooled streaming event processor with the given name.
static EventProcessorDefinition.ConfigurationStep<PooledStreamingEventProcessorConfiguration>	EventProcessorDefinition.pooledStreamingMatching(String name)	Creates a new processor definition for a pooled streaming event processor with the given name, automatically selecting any event handler with a namespace matching the name, and adding them to the pooled streaming event processor.

Uses of PooledStreamingEventProcessorConfiguration in org.axonframework.messaging.eventhandling.configuration

Methods in org.axonframework.messaging.eventhandling.configuration that return types with arguments of type PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
static EventProcessorModule.EventHandlingPhase<PooledStreamingEventProcessorModule,PooledStreamingEventProcessorConfiguration>	EventProcessorModule.pooledStreaming(String processorName)	Creates a PooledStreamingEventProcessorModule with the given name.

Uses of PooledStreamingEventProcessorConfiguration in org.axonframework.messaging.eventhandling.processing.streaming.pooled

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.addSegmentChangeListener(SegmentChangeListener segmentChangeListener)	Adds a listener invoked when segments are claimed or released.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.batchSize(int batchSize)	Specifies the number of events to be processed inside a single transaction.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.claimExtensionThreshold(long claimExtensionThreshold)	Specifies a time in milliseconds the work packages of this processor should extend the claim on a TrackingToken.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.clock(Clock clock)	Defines the Clock used for time dependent operation by this EventProcessor.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.coordinatorExecutor(ScheduledExecutorService coordinatorExecutor)	Specifies the ScheduledExecutorService used by the coordinator of this PooledStreamingEventProcessor.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.coordinatorExecutor(Supplier<ScheduledExecutorService> coordinatorExecutor)	Specifies the ScheduledExecutorService used by the coordinator of this PooledStreamingEventProcessor.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.deadLetterQueue(UnaryOperator<DeadLetterQueueConfiguration> customization)	Configures the Dead Letter Queue (DLQ) for this processor using a customization function.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.enableCoordinatorClaimExtension()	Enables the Coordinator to extend the claims of its WorkPackages.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.errorHandler(ErrorHandler errorHandler)
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.eventCriteria(Function<Set<QualifiedName>,EventCriteria> eventCriteriaProvider)	Sets the function to build the EventCriteria used to filter events when opening the event source.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.eventSource(StreamableEventSource eventSource)	Sets the StreamableEventSource (e.g. the EventStore) which this EventProcessor will track.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.ignoredMessageHandler(Consumer<? super EventMessage> ignoredMessageHandler)	Sets the handler, that is invoked when the event is ignored by all WorkPackages this Coordinator controls.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.initialSegmentCount(int initialSegmentCount)	Sets the initial segment count used to create segments on start up.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.initialToken(Function<TrackingTokenSource,CompletableFuture<TrackingToken>> initialToken)	Specifies the Function used to generate the initial TrackingTokens.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.maxClaimedSegments(int maxClaimedSegments)	Sets the maximum number of segments this instance may claim.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.maxSegmentProvider(MaxSegmentProvider maxSegmentProvider)	Defines the maximum number of segment this StreamingEventProcessor may claim per instance.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.schedulingProcessingContextProvider(Supplier<ProcessingContext> schedulingProcessingContextProvider)	Provides a ProcessingContext used to evaluate whether an event can be scheduled for processing by this WorkPackage.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.tokenClaimInterval(long tokenClaimInterval)	Specifies the time in milliseconds the processor's coordinator should wait after a failed attempt to claim any segments for processing.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.tokenStore(TokenStore tokenStore)	Sets the TokenStore used to store and fetch event tokens that enable this EventProcessor to track its progress.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.unitOfWorkFactory(UnitOfWorkFactory unitOfWorkFactory)
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.withInterceptor(MessageHandlerInterceptor<? super EventMessage> interceptor)	Registers the given EventMessage-specific MessageHandlerInterceptor for the PooledStreamingEventProcessor under construction.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.workerExecutor(ScheduledExecutorService workerExecutor)	Specifies the ScheduledExecutorService to be provided to the WorkPackages created by this PooledStreamingEventProcessor.
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.workerExecutor(Supplier<ScheduledExecutorService> workerExecutor)	Specifies the ScheduledExecutorService to be provided to the WorkPackages created by this PooledStreamingEventProcessor.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return types with arguments of type PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
EventProcessorModule.CustomizationPhase<PooledStreamingEventProcessorModule,PooledStreamingEventProcessorConfiguration>	PooledStreamingEventProcessorModule.eventHandlingComponents(Function<EventHandlingComponentsConfigurer.RequiredComponentPhase,EventHandlingComponentsConfigurer.CompletePhase> configurerTask)

Method parameters in org.axonframework.messaging.eventhandling.processing.streaming.pooled with type arguments of type PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
PooledStreamingEventProcessorModule	PooledStreamingEventProcessorModule.customized(BiFunction<Configuration,PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> instanceCustomization)
PooledStreamingEventProcessorModule	PooledStreamingEventProcessorModule.customized(BiFunction<Configuration,PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> instanceCustomization)
PooledStreamingEventProcessorsConfigurer	PooledStreamingEventProcessorsConfigurer.defaults(BiFunction<Configuration,PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> configureDefaults)	Configures default settings that will be applied to all PooledStreamingEventProcessor instances managed by this configurer.
PooledStreamingEventProcessorsConfigurer	PooledStreamingEventProcessorsConfigurer.defaults(BiFunction<Configuration,PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> configureDefaults)	Configures default settings that will be applied to all PooledStreamingEventProcessor instances managed by this configurer.
PooledStreamingEventProcessorsConfigurer	PooledStreamingEventProcessorsConfigurer.defaults(UnaryOperator<PooledStreamingEventProcessorConfiguration> configureDefaults)	Configures default settings that will be applied to all PooledStreamingEventProcessor instances managed by this configurer.
PooledStreamingEventProcessorsConfigurer	PooledStreamingEventProcessorsConfigurer.processor(String name, Function<EventProcessorModule.EventHandlingPhase<PooledStreamingEventProcessorModule,PooledStreamingEventProcessorConfiguration>,PooledStreamingEventProcessorModule> moduleCustomizer)	Registers a pooled streaming event processor with custom module configuration.

Constructors in org.axonframework.messaging.eventhandling.processing.streaming.pooled with parameters of type PooledStreamingEventProcessorConfiguration

Modifier	Constructor	Description
	PooledStreamingEventProcessor(String name, List<EventHandlingComponent> eventHandlingComponents, PooledStreamingEventProcessorConfiguration configuration)	Instantiate a PooledStreamingEventProcessor with given name, eventHandlingComponents and based on the fields contained in the PooledStreamingEventProcessorConfiguration.