org.axonframework.springboot

Class EventProcessorProperties.ProcessorSettings

java.lang.Object

org.axonframework.springboot.EventProcessorProperties.ProcessorSettings

Enclosing class:

EventProcessorProperties

public static class EventProcessorProperties.ProcessorSettings
extends Object

Constructor Summary

Constructors

Constructor and Description
ProcessorSettings()

Method Summary

Modifier and Type	Method and Description
int	getBatchSize() Returns the maximum size of a processing batch.
Integer	getInitialSegmentCount() Returns the number of initial segments that should be created, if no segments are already present.
EventProcessorProperties.Mode	getMode() Returns the type of processor to configure.
String	getSequencingPolicy() Returns the name of the bean that defines the SequencingPolicy for this processor.
String	getSource() Returns the name of the bean that should be used as source for Event Messages.
int	getThreadCount() Returns the number of threads to use to process Events, when using a StreamingEventProcessor implementation.
long	getTokenClaimInterval() Returns the interval between attempts to claim tokens by a StreamingEventProcessor.
TimeUnit	getTokenClaimIntervalTimeUnit() Returns the time unit used to define tokens claim interval.
void	setBatchSize(int batchSize) Sets the maximum size of a processing batch.
void	setInitialSegmentCount(Integer initialSegmentCount) Sets the number of initial segments that should be created, if no segments are already present.
void	setMode(EventProcessorProperties.Mode mode) Sets the type of processor that should be configured.
void	setSequencingPolicy(String sequencingPolicy) Sets the name of the bean that defines the SequencingPolicy for this processor.
void	setSource(String source) Sets the name of the bean that should be used as source for Event Messages.
void	setThreadCount(int threadCount) Sets the number of threads to use to process Events, when using a StreamingEventProcessor implementation.
void	setTokenClaimInterval(long tokenClaimInterval) Sets the time to wait after a failed attempt to claim any token, before making another attempt.
void	setTokenClaimIntervalTimeUnit(TimeUnit tokenClaimIntervalTimeUnit) Sets the time unit used to defined tokens claim interval.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProcessorSettings

public ProcessorSettings()

Method Detail

getSource

public String getSource()

Returns the name of the bean that should be used as source for Event Messages. If not provided, the EventBus is used as source.

Returns:

the name of the bean that should be used as source for Event Messages.

setSource

public void setSource(String source)

Sets the name of the bean that should be used as source for Event Messages.

Parameters:

source - the name of the bean that should be used as source for Event Messages.

getMode

public EventProcessorProperties.Mode getMode()

Returns the type of processor to configure. Defaults to EventProcessorProperties.Mode.TRACKING.

Returns:

the type of processor to configure.

setMode

public void setMode(EventProcessorProperties.Mode mode)

Sets the type of processor that should be configured. Defaults to EventProcessorProperties.Mode.TRACKING.

Parameters:

mode - the type of processor that should be configured.

getInitialSegmentCount

public Integer getInitialSegmentCount()

Returns the number of initial segments that should be created, if no segments are already present. Defaults to 1 for a TrackingEventProcessor and 16 for a PooledStreamingEventProcessor.

If the threadCount is not further specified, the initial segment count will be used for this too.

Returns:

the number of initial segments that should be created.

setInitialSegmentCount

public void setInitialSegmentCount(Integer initialSegmentCount)

Sets the number of initial segments that should be created, if no segments are already present. Defaults to 1 for a TrackingEventProcessor and 16 for a PooledStreamingEventProcessor.

If the threadCount is not further specified, the initial segment count will be used for this too.

Parameters:

initialSegmentCount - the number of initial segments that should be created.

getTokenClaimInterval

public long getTokenClaimInterval()

Returns the interval between attempts to claim tokens by a StreamingEventProcessor. Defaults to 5000 milliseconds.

Returns:

the interval between attempts to claim tokens by a StreamingEventProcessor.

setTokenClaimInterval

public void setTokenClaimInterval(long tokenClaimInterval)

Sets the time to wait after a failed attempt to claim any token, before making another attempt. Defaults to 5000 milliseconds.

Parameters:

tokenClaimInterval - the interval between attempts to claim tokens by a TrackingEventProcessor.

getTokenClaimIntervalTimeUnit

public TimeUnit getTokenClaimIntervalTimeUnit()

Returns the time unit used to define tokens claim interval. Defaults to TimeUnit.MILLISECONDS.

Returns:

the time unit used to defined tokens claim interval.

setTokenClaimIntervalTimeUnit

public void setTokenClaimIntervalTimeUnit(TimeUnit tokenClaimIntervalTimeUnit)

Sets the time unit used to defined tokens claim interval. It must be a valid value of TimeUnit. Defaults to TimeUnit.MILLISECONDS.

Parameters:

tokenClaimIntervalTimeUnit - the time unit used to defined tokens claim interval.

getThreadCount

public int getThreadCount()

Returns the number of threads to use to process Events, when using a StreamingEventProcessor implementation. Defaults to the configured number of initial segments. If this field is not configured, the thread count defaults to 1 for a TrackingEventProcessor and 4 for a PooledStreamingEventProcessor.

Returns:

the number of threads to use to process Events.

setThreadCount

public void setThreadCount(int threadCount)

Sets the number of threads to use to process Events, when using a StreamingEventProcessor implementation. Defaults to the configured number of initial segments. If this field is not configured, the thread count defaults to 1 for a TrackingEventProcessor and 4 for a PooledStreamingEventProcessor.

A provided threadCount < 0 will result in a number of threads equal to the configured number of setInitialSegmentCount(Integer) initial segments.

Parameters:

threadCount - the number of threads to use to process Events.

getBatchSize

public int getBatchSize()

Returns the maximum size of a processing batch. This is the number of events that a processor in "tracking" and "pooled" mode will attempt to read and process within a single Unit of Work / Transaction.

Returns:

the maximum size of a processing batch.

setBatchSize

public void setBatchSize(int batchSize)

Sets the maximum size of a processing batch. This is the number of events that a processor in "tracking" and "pooled" mode will attempt to read and process within a single Unit of Work / Transaction. Defaults to 1.

Parameters:

batchSize - the maximum size of a processing batch.

getSequencingPolicy

public String getSequencingPolicy()

Returns the name of the bean that defines the SequencingPolicy for this processor.

Returns:

the name of the bean that defines the SequencingPolicy for this processor.

setSequencingPolicy

public void setSequencingPolicy(String sequencingPolicy)

Sets the name of the bean that defines the SequencingPolicy for this processor. The SequencingPolicy describes which Events must be handled sequentially, and which can be handled concurrently. Defaults to a SequentialPerAggregatePolicy.

Parameters:

sequencingPolicy - the name of the bean that defines the SequencingPolicy for this processor.