fr.sii.ogham.core.retry

Class PerExecutionDelayRetry

java.lang.Object

fr.sii.ogham.core.retry.PerExecutionDelayRetry

All Implemented Interfaces:

RetryStrategy

public class PerExecutionDelayRetry
extends Object
implements RetryStrategy

Retry several times with a fixed delay to wait after the last execution failure until the maximum attempts is reached. A specific delay is used between each execution. If there are more attempts than the configured delays, the last delay is used for remaining attempts. If maximum attempts are set to 5 and delays are configured like this:

1. 500ms
2. 750ms
3. 1800ms

If the action (named "connect" for the example) takes 100ms to execute before failing, here is what happens:

• 0: connect
• 100: timeout
• 600: connect
• 700: timeout
• 1450: connect
• 1550: timeout
• 3350: connect
• 3450: timeout
• 5250: connect
• 5350: timeout
• 7150: connect
• 7250: timeout
• fail

Author:

Aurélien Baudet

Constructor Summary

Constructors

Constructor and Description
PerExecutionDelayRetry(int maxRetries, List<Long> delays) Initializes with the maximum attempts and the delays to wait after a failure.

Method Summary

Modifier and Type	Method and Description
List<Long>	getDelays()
int	getMaxRetries()
int	getRemainingRetries()
Instant	nextDate(Instant executionStartTime, Instant executionFailureTime) Indicate the next date when the next retry should operate.
boolean	terminated() Indicate that retries should stop now.

Methods inherited from class java.lang.Object

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

Constructor Detail

PerExecutionDelayRetry

public PerExecutionDelayRetry(int maxRetries,
                              List<Long> delays)

Initializes with the maximum attempts and the delays to wait after a failure.

Parameters:

maxRetries - the maximum attempts

delays - the delays to wait after failure to do another attempt

Method Detail

terminated

public boolean terminated()

Description copied from interface: RetryStrategy

Indicate that retries should stop now. Strategy may be based on a number of attempts or a end date or anything else.

Specified by:

terminated in interface RetryStrategy

Returns:

true if retries should stop, false otherwise

nextDate

public Instant nextDate(Instant executionStartTime,
                        Instant executionFailureTime)

Description copied from interface: RetryStrategy

Indicate the next date when the next retry should operate. Strategy may define a fixed delay, random delay, exponential delay or anything else.

Specified by:

nextDate in interface RetryStrategy

Parameters:

executionStartTime - the date and time when the action has been started

executionFailureTime - the date and time when the action has failed

Returns:

the next execution date

getRemainingRetries

public int getRemainingRetries()

getMaxRetries

public int getMaxRetries()

getDelays

public List<Long> getDelays()