Package 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	Description
static class	ExponentialBackOffIntervalRetryScheduler.Builder	Builder class to instantiate an ExponentialBackOffIntervalRetryScheduler.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ExponentialBackOffIntervalRetryScheduler(ExponentialBackOffIntervalRetryScheduler.Builder builder)	Instantiate an ExponentialBackOffIntervalRetryScheduler. the settings are copied from the ExponentialBackOffIntervalRetryScheduler.Builder and validated.

Method Summary

Modifier and Type	Method	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 Details

ExponentialBackOffIntervalRetryScheduler

protected ExponentialBackOffIntervalRetryScheduler(ExponentialBackOffIntervalRetryScheduler.Builder builder)

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

Parameters:

builder -

Method Details

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.