Modifier and Type | Class and Description |
---|---|
static class |
RetryPolicy.Exponential
Implementation for the exponential retry policy.
|
static class |
RetryPolicy.Linear
Implementation for the linear retry policy.
|
static class |
RetryPolicy.Timed
Implementation for the timed retry policy.
|
Modifier and Type | Method and Description |
---|---|
static RetryPolicy |
RetryPolicy.linear(long duration,
TimeUnit unit)
Build a linear retry policy.
|
static RetryPolicy |
RetryPolicy.timed(long duration,
TimeUnit unit,
RetryPolicy policy)
Wrap an existing retry policy which is only valid for a given time.
|
Modifier and Type | Method and Description |
---|---|
<T> Stage<RetryResult<T>> |
CoreAsync.retryUntilCompleted(Callable<? extends Stage<T>> callable,
RetryPolicy policy) |
<T> Stage<RetryResult<T>> |
Async.retryUntilCompleted(Callable<? extends Stage<T>> callable,
RetryPolicy policy)
Retry the given action until it has been completed, or the provided
RetryPolicy expire. |
<T> Stage<RetryResult<T>> |
CoreAsync.retryUntilCompleted(Callable<? extends Stage<T>> callable,
RetryPolicy policy,
ClockSource clockSource) |
<T> Stage<RetryResult<T>> |
Async.retryUntilCompleted(Callable<? extends Stage<T>> callable,
RetryPolicy policy,
ClockSource clockSource)
Retry the given action until it has been completed, or the provided
RetryPolicy expire. |
static RetryPolicy |
RetryPolicy.timed(long duration,
TimeUnit unit,
RetryPolicy policy)
Wrap an existing retry policy which is only valid for a given time.
|
Copyright © 2017. All rights reserved.