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

Packages that use PooledStreamingEventProcessorConfiguration

Package	Description
io.axoniq.framework.workflow.configuration	Package containing workflow configuration components.
org.axonframework.extension.spring.config
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 io.axoniq.framework.workflow.configuration

Method parameters in io.axoniq.framework.workflow.configuration with type arguments of type PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
WorkflowModule.OptionalPhase<C>	WorkflowModule.OptionalPhase.historyProcessorConfiguration(Function<PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> historyProcessorConfiguration)	Applies the given historyProcessorConfiguration function to the PooledStreamingEventProcessorConfiguration backing the history projector's own, dedicated event processor.
WorkflowModule.OptionalPhase<C>	WorkflowModule.OptionalPhase.historyProcessorConfiguration(Function<PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> historyProcessorConfiguration)	Applies the given historyProcessorConfiguration function to the PooledStreamingEventProcessorConfiguration backing the history projector's own, dedicated event processor.
WorkflowModule.OptionalPhase<C>	WorkflowModule.OptionalPhase.processorConfiguration(Function<PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> processorConfiguration)	Applies the given processorConfiguration function to the PooledStreamingEventProcessorConfiguration backing this module's event processor.
WorkflowModule.OptionalPhase<C>	WorkflowModule.OptionalPhase.processorConfiguration(Function<PooledStreamingEventProcessorConfiguration,PooledStreamingEventProcessorConfiguration> processorConfiguration)	Applies the given processorConfiguration function to the PooledStreamingEventProcessorConfiguration backing this module's event processor.

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.

Method parameters in org.axonframework.extension.spring.config with type arguments of type PooledStreamingEventProcessorConfiguration

Modifier and Type	Method	Description
SagaProcessorDefinition	SagaProcessorDefinition.Selector.whenPooledStreaming(UnaryOperator<PooledStreamingEventProcessorConfiguration> customization)	Completes the definition with a customization applied only when the selected processor runs in pooled streaming mode, which is the default for a Saga.

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)	Deprecated, for removal: This API element is subject to removal in a future version. Use ClockUtils.set(Clock) if you have to provide a non-default Clock instance.
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.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.
<T extends ConfigurationExtension<?>> PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.extend(Class<T> extensionType, Supplier<T> factory)
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.progressStrategyFactoryBuilder(Function<List<EventHandlingComponent>,SegmentProgressStrategyFactory> progressStrategyFactoryBuilder)	Sets the function selecting the SegmentProgressStrategyFactory for a processor from its EventHandlingComponents.
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.sequencingPolicy(SequencingPolicy<? super EventMessage> sequencingPolicy)	Sets the SequencingPolicy used to determine the sequence identifier of events handled by this PooledStreamingEventProcessor, whenever an assigned EventHandlingComponent does not define a more specific one.
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.