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.
int	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 Sequencing Policy 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 in "tracking" mode.
long	getTokenClaimInterval() Returns the interval between attempts to claim tokens by a TrackingEventProcessor.
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(int 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 Sequencing Policy 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 in "tracking" mode.
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.

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 "subscribing".

Parameters:

mode - the type of processor that should be configured.

getInitialSegmentCount

public int getInitialSegmentCount()

Returns the number of initial segments that should be created, if no segments are already present. Is also used as the thread count if it is not further specified.

Returns:

the number of initial segments that should be created.

setInitialSegmentCount

public void setInitialSegmentCount(int initialSegmentCount)

Sets the number of initial segments that should be created, if no segments are already present. Defaults to 1. Will also be used as the thread count if it is not further specified.

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 TrackingEventProcessor. Defaults to 5000 milliseconds.

Returns:

the interval between attempts to claim tokens by a TrackingEventProcessor.

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 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 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 in "tracking" mode. Defaults to the number of initial segments.

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 in "tracking" mode. Defaults to the number of initial segments.

A provided threadCount < 0 will result in a number of threads equal to the configured number of 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" 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" 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 Sequencing Policy for this processor.

Returns:

the name of the bean that defines the Sequencing Policy for this processor.

setSequencingPolicy

public void setSequencingPolicy(String sequencingPolicy)

Sets the name of the bean that defines the Sequencing Policy for this processor. The Sequencing Policy 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 Sequencing Policy for this processor.