org.axonframework.commandhandling.gateway

Class IntervalRetryScheduler.Builder

java.lang.Object

org.axonframework.commandhandling.gateway.IntervalRetryScheduler.Builder

Enclosing class:

IntervalRetryScheduler

public static class IntervalRetryScheduler.Builder
extends Object

Builder class to instantiate a IntervalRetryScheduler.

The default for retryInterval is set to 100ms, while maxRetryCount gets a single retry. The retryInterval, maxRetryCount and ScheduledExecutorService are hard requirements and as such should be provided.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
IntervalRetryScheduler	build() Initializes a IntervalRetryScheduler as specified through this Builder.
IntervalRetryScheduler.Builder	maxRetryCount(int maxRetryCount) Sets the maximum number of retries allowed for a single command, defaulted to 1.
IntervalRetryScheduler.Builder	retryExecutor(ScheduledExecutorService retryExecutor) Sets the ScheduledExecutorService used to schedule a command retry.
IntervalRetryScheduler.Builder	retryInterval(int retryInterval) Sets the retry interval in milliseconds at which to schedule a retry, defaulted to 100ms.
protected void	validate() Validates whether the fields contained in this Builder are set accordingly.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

retryInterval

public IntervalRetryScheduler.Builder retryInterval(int retryInterval)

Sets the retry interval in milliseconds at which to schedule a retry, defaulted to 100ms.

Parameters:

retryInterval - an int specifying the retry interval in milliseconds at which to schedule a retry

Returns:

the current Builder instance, for fluent interfacing

maxRetryCount

public IntervalRetryScheduler.Builder maxRetryCount(int maxRetryCount)

Sets the maximum number of retries allowed for a single command, defaulted to 1.

Parameters:

maxRetryCount - an int specifying the maximum number of retries allowed for a single command

Returns:

the current Builder instance, for fluent interfacing

retryExecutor

public IntervalRetryScheduler.Builder retryExecutor(ScheduledExecutorService retryExecutor)

Sets the ScheduledExecutorService used to schedule a command retry.

Parameters:

retryExecutor - a ScheduledExecutorService used to schedule a command retry

Returns:

the current Builder instance, for fluent interfacing

build

public IntervalRetryScheduler build()

Initializes a IntervalRetryScheduler as specified through this Builder.

Returns:

a IntervalRetryScheduler as specified through this Builder

validate

protected void validate()
                 throws AxonConfigurationException

Validates whether the fields contained in this Builder are set accordingly.

Throws:

AxonConfigurationException - if one field is asserted to be incorrect according to the Builder's specifications