org.axonframework.saga.annotation
Class RetryingErrorHandler.TimeoutConfiguration

java.lang.Object
  org.axonframework.saga.annotation.RetryingErrorHandler.TimeoutConfiguration

Enclosing class:

RetryingErrorHandler

public static class RetryingErrorHandler.TimeoutConfiguration
extends Object

Definition of a timeout to use for a specific range of retries

Constructor Summary

RetryingErrorHandler.TimeoutConfiguration(int count, long timeout, TimeUnit timeUnit)
Initialize a configuration to apply the given timeout between retries for the given count number of retries.

RetryingErrorHandler.TimeoutConfiguration(long timeout, TimeUnit timeUnit)
Initialize a configuration to indefinitely retry, applying the given timeout between retries.

Method Summary

int	count() The number of times to apply the retryPolicy.
RetryPolicy	retryPolicy() The retry policy to use between retries

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryingErrorHandler.TimeoutConfiguration

public RetryingErrorHandler.TimeoutConfiguration(long timeout,
                                                 TimeUnit timeUnit)

Initialize a configuration to indefinitely retry, applying the given timeout between retries.

Parameters:

timeout - The amount of time to wait before the next retry

timeUnit - The unit of the timeout

RetryingErrorHandler.TimeoutConfiguration

public RetryingErrorHandler.TimeoutConfiguration(int count,
                                                 long timeout,
                                                 TimeUnit timeUnit)

Initialize a configuration to apply the given timeout between retries for the given count number of retries.

Parameters:

count - The number of retries to apply the given timeout for

timeout - The amount of time to wait before the next retry

timeUnit - The unit of the timeout

Method Detail

count

public int count()

The number of times to apply the retryPolicy.

Returns:

number of times to apply the retryPolicy

retryPolicy

public RetryPolicy retryPolicy()

The retry policy to use between retries

Returns:

the retry policy to use between retries