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

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.

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.