org.axonframework.commandhandling.gateway

Class ExponentialBackOffIntervalRetryScheduler

java.lang.Object

org.axonframework.commandhandling.gateway.AbstractRetryScheduler

org.axonframework.commandhandling.gateway.ExponentialBackOffIntervalRetryScheduler

All Implemented Interfaces:

RetryScheduler

public class ExponentialBackOffIntervalRetryScheduler
extends AbstractRetryScheduler

A RetryScheduler that uses a backoff strategy, retrying commands at increasing 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:

4.2

Author:

Bert Laverman

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExponentialBackOffIntervalRetryScheduler.Builder Builder class to instantiate an ExponentialBackOffIntervalRetryScheduler.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ExponentialBackOffIntervalRetryScheduler(ExponentialBackOffIntervalRetryScheduler.Builder builder) Instantiate an ExponentialBackOffIntervalRetryScheduler.

Method Summary

Modifier and Type	Method and Description
static ExponentialBackOffIntervalRetryScheduler.Builder	builder() Instantiate a Builder to be able to create a ExponentialBackOffIntervalRetryScheduler.
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

ExponentialBackOffIntervalRetryScheduler

protected ExponentialBackOffIntervalRetryScheduler(ExponentialBackOffIntervalRetryScheduler.Builder builder)

Instantiate an ExponentialBackOffIntervalRetryScheduler. the settings are copied from the ExponentialBackOffIntervalRetryScheduler.Builder and validated.

Parameters:

builder -

Method Detail

builder

public static ExponentialBackOffIntervalRetryScheduler.Builder builder()

Instantiate a Builder to be able to create a ExponentialBackOffIntervalRetryScheduler.

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 ExponentialBackOffIntervalRetryScheduler

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.