Package org.axonframework.extension.spring.config

Interface EventProcessorSettings.PooledEventProcessorSettings

All Superinterfaces:

EventProcessorSettings

All Known Implementing Classes:

EventProcessorProperties.ProcessorSettings

Enclosing interface:

EventProcessorSettings

public static non-sealed interface EventProcessorSettings.PooledEventProcessorSettings
extends EventProcessorSettings

Settings for pooled event processor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.axonframework.extension.spring.config.EventProcessorSettings

EventProcessorSettings.MapWrapper, EventProcessorSettings.PooledEventProcessorSettings, EventProcessorSettings.ProcessorMode, EventProcessorSettings.SubscribingEventProcessorSettings

Field Summary

Fields inherited from interface org.axonframework.extension.spring.config.EventProcessorSettings

DEFAULT

Method Summary

Modifier and Type	Method	Description
int	batchSize()	Batch size for the pooled processor.
int	initialSegmentCount()	Initial segment count.
default EventProcessorSettings.ProcessorMode	processorMode()	Retrieves the processor mode.
int	threadCount()	Thread count for pooled processor.
long	tokenClaimIntervalInMillis()	Retrieves token claim interval.
@Nullable String	tokenStore()	Name of the bean acting as token store for this pooled streaming processor.

Methods inherited from interface org.axonframework.extension.spring.config.EventProcessorSettings

source

Method Details

processorMode

default EventProcessorSettings.ProcessorMode processorMode()

Retrieves the processor mode.

Specified by:

processorMode in interface EventProcessorSettings

Returns:

processor mode.

initialSegmentCount

int initialSegmentCount()

Initial segment count.

Returns:

returns initial segment count.

tokenClaimIntervalInMillis

long tokenClaimIntervalInMillis()

Retrieves token claim interval.

Returns:

interval in milliseconds.

threadCount

int threadCount()

Thread count for pooled processor.

Returns:

a positive integer describing the size of the thread pool.

batchSize

int batchSize()

Batch size for the pooled processor.

Returns:

a positive integer describing the size of the batch.

tokenStore

@Nullable String tokenStore()

Name of the bean acting as token store for this pooled streaming processor.

Returns:

only used if non-null.