org.axonframework.commandhandling.gateway

Class IntervalRetryScheduler

java.lang.Object

org.axonframework.commandhandling.gateway.AbstractRetryScheduler

org.axonframework.commandhandling.gateway.IntervalRetryScheduler

All Implemented Interfaces:

RetryScheduler

public class IntervalRetryScheduler
extends AbstractRetryScheduler

RetryScheduler implementation that retries commands at regular intervals when they fail because of an exception that is not explicitly non-transient. Checked exceptions are considered non-transient and will not result in a retry.

Since:

2.0

Author:

Allard Buijze

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IntervalRetryScheduler.Builder Builder class to instantiate a IntervalRetryScheduler.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	IntervalRetryScheduler(IntervalRetryScheduler.Builder builder) Instantiate a IntervalRetryScheduler based on the fields contained in the IntervalRetryScheduler.Builder.

Method Summary

Modifier and Type	Method and Description
static IntervalRetryScheduler.Builder	builder() Instantiate a Builder to be able to create a IntervalRetryScheduler.
protected long	computeRetryInterval(CommandMessage commandMessage, RuntimeException lastFailure, List<Class<? extends Throwable>[]> failures) Compute the amount of milliseconds delay until the next retry, given the information passed.

Methods inherited from class org.axonframework.commandhandling.gateway.AbstractRetryScheduler

isExplicitlyNonTransient, scheduleRetry, scheduleRetry

Methods inherited from class java.lang.Object

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

Constructor Detail

IntervalRetryScheduler

protected IntervalRetryScheduler(IntervalRetryScheduler.Builder builder)

Instantiate a IntervalRetryScheduler based on the fields contained in the IntervalRetryScheduler.Builder.

Will assert that the retryInterval and maxRetryCount are positive numbers, and that the ScheduledExecutorService is not null. If any of these does not hold, an AxonConfigurationException will be thrown.

Parameters:

builder - the IntervalRetryScheduler.Builder used to instantiate a IntervalRetryScheduler instance

Method Detail

computeRetryInterval

protected long computeRetryInterval(CommandMessage commandMessage,
                                    RuntimeException lastFailure,
                                    List<Class<? extends Throwable>[]> failures)

Description copied from class: AbstractRetryScheduler

Compute the amount of milliseconds delay until the next retry, given the information passed.

Specified by:

computeRetryInterval in class AbstractRetryScheduler

Parameters:

commandMessage - the command that was sent (and failed).

lastFailure - the last failure that caused this retry scheduler to be called.

failures - a List of all failures up to now.

Returns:

the number of milliseconds to wait until retrying.

builder

public static IntervalRetryScheduler.Builder builder()

Instantiate a Builder to be able to create a IntervalRetryScheduler.

The default for maxRetryCount is set to a single retry, the backoffFactor defaults to 100ms and the nonTransientFailurePredicate defaults to AxonNonTransientExceptionClassesPredicate. The ScheduledExecutorService is a hard requirement and as such should be provided.

Returns:

a Builder to be able to create a IntervalRetryScheduler