org.springframework.retry.policy

Class SimpleRetryPolicy

java.lang.Object

org.springframework.retry.policy.SimpleRetryPolicy

All Implemented Interfaces:

RetryPolicy

public class SimpleRetryPolicy
extends java.lang.Object
implements RetryPolicy

Simple retry policy that retries a fixed number of times for a set of named exceptions (and subclasses). The number of attempts includes the initial try, so e.g.

 retryTemplate = new RetryTemplate(new SimpleRetryPolicy(3));
 retryTemplate.execute(callback);
 

will execute the callback at least once, and as many as 3 times.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	SimpleRetryPolicy.SimpleRetryContext

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_ATTEMPTS The default limit to the number of attempts for a new policy.
private int	maxAttempts
private BinaryExceptionClassifier	retryableClassifier

Constructor Summary

Constructors

Constructor and Description
SimpleRetryPolicy() Create a SimpleRetryPolicy with the default number of retry attempts.
SimpleRetryPolicy(int maxAttempts, java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptions) Create a SimpleRetryPolicy with the specified number of retry attempts.
SimpleRetryPolicy(int maxAttempts, java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptions, boolean traverseCauses) Create a SimpleRetryPolicy with the specified number of retry attempts.

Method Summary

Modifier and Type	Method and Description
boolean	canRetry(RetryContext context) Test for retryable operation based on the status.
void	close(RetryContext status)
int	getMaxAttempts() The maximum number of retry attempts before failure.
RetryContext	open(RetryContext parent) Get a status object that can be used to track the current operation according to this policy.
void	registerThrowable(RetryContext context, java.lang.Throwable throwable) Update the status with another attempted retry and the latest exception.
private boolean	retryForException(java.lang.Throwable ex) Delegates to an exception classifier.
void	setMaxAttempts(int retryAttempts) Setter for retry attempts.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_ATTEMPTS

public static final int DEFAULT_MAX_ATTEMPTS

The default limit to the number of attempts for a new policy.

See Also:

Constant Field Values

maxAttempts

private volatile int maxAttempts

retryableClassifier

private BinaryExceptionClassifier retryableClassifier

Constructor Detail

SimpleRetryPolicy

public SimpleRetryPolicy()

Create a SimpleRetryPolicy with the default number of retry attempts.

SimpleRetryPolicy

public SimpleRetryPolicy(int maxAttempts,
                         java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptions)

Create a SimpleRetryPolicy with the specified number of retry attempts.

Parameters:

maxAttempts -

retryableExceptions -

SimpleRetryPolicy

public SimpleRetryPolicy(int maxAttempts,
                         java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptions,
                         boolean traverseCauses)

Create a SimpleRetryPolicy with the specified number of retry attempts. If traverseCauses is true, the exception causes will be traversed until a match is found.

Parameters:

maxAttempts -

retryableExceptions -

traverseCauses -

Method Detail

setMaxAttempts

public void setMaxAttempts(int retryAttempts)

Setter for retry attempts.

Parameters:

retryAttempts - the number of attempts before a retry becomes impossible.

getMaxAttempts

public int getMaxAttempts()

The maximum number of retry attempts before failure.

Returns:

the maximum number of attempts

canRetry

public boolean canRetry(RetryContext context)

Test for retryable operation based on the status.

Specified by:

canRetry in interface RetryPolicy

Parameters:

context - the current retry status

Returns:

true if the last exception was retryable and the number of attempts so far is less than the limit.

See Also:

RetryPolicy.canRetry(org.springframework.retry.RetryContext)

close

public void close(RetryContext status)

Specified by:

close in interface RetryPolicy

Parameters:

status - a retry status created by the RetryPolicy.open(RetryContext) method of this manager.

See Also:

RetryPolicy.close(RetryContext)

registerThrowable

public void registerThrowable(RetryContext context,
                              java.lang.Throwable throwable)

Update the status with another attempted retry and the latest exception.

Specified by:

registerThrowable in interface RetryPolicy

Parameters:

context - the current status object.

See Also:

RetryPolicy.registerThrowable(RetryContext, Throwable)

open

public RetryContext open(RetryContext parent)

Get a status object that can be used to track the current operation according to this policy. Has to be aware of the latest exception and the number of attempts.

Specified by:

open in interface RetryPolicy

Parameters:

parent - the parent context if we are in a nested retry.

Returns:

a RetryContext object specific to this manager.

See Also:

RetryPolicy.open(RetryContext)

retryForException

private boolean retryForException(java.lang.Throwable ex)

Delegates to an exception classifier.

Parameters:

ex -

Returns:

true if this exception or its ancestors have been registered as retryable.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object