org.axonframework.commandhandling.gateway

Class AbstractRetryScheduler.Builder<B extends AbstractRetryScheduler.Builder>

java.lang.Object

org.axonframework.commandhandling.gateway.AbstractRetryScheduler.Builder<B>

Direct Known Subclasses:

ExponentialBackOffIntervalRetryScheduler.Builder, IntervalRetryScheduler.Builder

Enclosing class:

AbstractRetryScheduler

public abstract static class AbstractRetryScheduler.Builder<B extends AbstractRetryScheduler.Builder>
extends Object

A builder class for the RetryScheduler implementations.

The default for maxRetryCount is set to a single retry. The ScheduledExecutorService is a hard requirement and as such should be provided.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
B	maxRetryCount(int maxRetryCount) Sets the maximum number of retries allowed for a single command.
B	retryExecutor(ScheduledExecutorService retryExecutor) Sets the ScheduledExecutorService used to schedule a command retry.
protected void	validate() Validate the fields.

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

retryExecutor

public B 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

maxRetryCount

public B maxRetryCount(int maxRetryCount)

Sets the maximum number of retries allowed for a single command. Defaults 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

validate

protected void validate()
                 throws AxonConfigurationException

Validate the fields. This method is called in the AbstractRetryScheduler's constructor.

Throws:

AxonConfigurationException - if validation fails.