org.spf4j.failsafe

Class RetryPolicy<T,C extends Callable<? extends T>>

java.lang.Object

org.spf4j.failsafe.RetryPolicy<T,C>

All Implemented Interfaces:

SyncRetryExecutor<T,C>

@ParametersAreNonnullByDefault
public class RetryPolicy<T,C extends Callable<? extends T>>
extends Object
implements SyncRetryExecutor<T,C>

Author:

Zoltan Farkas

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RetryPolicy.Builder<T,C extends Callable<? extends T>>

Method Summary

Modifier and Type	Method and Description
AsyncRetryExecutor	async()
AsyncRetryExecutor<T,C>	async(RetryExecutor exec)
<R extends T,W extends C,EX extends Exception> R	call(W pwhat, Class<EX> exceptionClass, long startNanos, long deadlineNanos)
static <T,C extends Callable<? extends T>> RetryPolicy<T,C>	defaultPolicy()
RetryPredicate<T,C>	getRetryPredicate(long startTimeNanos, long deadlineNanos)
static <T,C extends Callable<? extends T>> RetryPolicy.Builder<T,C>	newBuilder() Create a retry policy builder.
static <T,C extends Callable<? extends T>> RetryPolicy<T,C>	noRetryPolicy()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.spf4j.failsafe.SyncRetryExecutor

call, call, call, call, run, run, run

Method Detail

noRetryPolicy

public static <T,C extends Callable<? extends T>> RetryPolicy<T,C> noRetryPolicy()

defaultPolicy

public static <T,C extends Callable<? extends T>> RetryPolicy<T,C> defaultPolicy()

call

public final <R extends T,W extends C,EX extends Exception> R call(W pwhat,
                                                                   Class<EX> exceptionClass,
                                                                   long startNanos,
                                                                   long deadlineNanos)
                                                            throws InterruptedException,
                                                                   TimeoutException,
                                                                   EX extends Exception

Specified by:

call in interface SyncRetryExecutor<T,C extends Callable<? extends T>>

Throws:

InterruptedException

TimeoutException

EX extends Exception

async

public final AsyncRetryExecutor<T,C> async(RetryExecutor exec)

async

public final AsyncRetryExecutor async()

getRetryPredicate

public final RetryPredicate<T,C> getRetryPredicate(long startTimeNanos,
                                                   long deadlineNanos)

toString

public String toString()

Overrides:

toString in class Object

Returns:

string representation of policy.

newBuilder

@CheckReturnValue
public static <T,C extends Callable<? extends T>> RetryPolicy.Builder<T,C> newBuilder()

Create a retry policy builder.

Type Parameters:

T - the Type returned by the retried callables.

C - the type of the Callable's returned.

Returns: