org.spf4j.failsafe

Interface RetryDecision<T,C extends Callable<? extends T>>

public interface RetryDecision<T,C extends Callable<? extends T>>

Author:

Zoltan Farkas

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	RetryDecision.Type

Field Summary

Fields

Modifier and Type	Field and Description
static RetryDecision<?,?>	ABORT

Method Summary

Modifier and Type	Method and Description
static RetryDecision	abort()
static <T> RetryDecision<T,? extends Callable<? extends T>>	abortReturn(T result) Abort operation and return the provided Object.
static RetryDecision	abortThrow(Exception exception) Abort operation with a custom Exception.
RetryDecision.Type	getDecisionType()
long	getDelayNanos()
C	getNewCallable()
Either<Exception,T>	getResult()
static <T,C extends Callable<? extends T>> RetryDecision<T,C>	retry(long retryNanos, C callable)
static <T,C extends Callable<? extends T>> RetryDecision<T,C>	retry(long time, TimeUnit unit, C callable)
static <T,C extends Callable<? extends T>> RetryDecision<T,C>	retryDefault(C callable)

Field Detail

ABORT

static final RetryDecision<?,?> ABORT

Method Detail

abort

@CheckReturnValue
static RetryDecision abort()

Returns:

Create Abort retry decision. The last successful result or exception is returned.

abortThrow

@CheckReturnValue
static RetryDecision abortThrow(@Nonnull
                                                  Exception exception)

Abort operation with a custom Exception.

Parameters:

exception - the custom exception.

Returns:

a Abort decision with a custom Exception.

abortReturn

@CheckReturnValue
static <T> RetryDecision<T,? extends Callable<? extends T>> abortReturn(T result)

Abort operation and return the provided Object.

Parameters:

result -

Returns:

retry

@CheckReturnValue
static <T,C extends Callable<? extends T>> RetryDecision<T,C> retry(@Nonnegative
                                                                                      long time,
                                                                                      TimeUnit unit,
                                                                                      @Nonnull
                                                                                      C callable)

retry

@CheckReturnValue
static <T,C extends Callable<? extends T>> RetryDecision<T,C> retry(@Nonnegative
                                                                                      long retryNanos,
                                                                                      @Nonnull
                                                                                      C callable)

retryDefault

@CheckReturnValue
static <T,C extends Callable<? extends T>> RetryDecision<T,C> retryDefault(@Nonnull
                                                                                             C callable)

getDecisionType

@CheckReturnValue
 @Nonnull
RetryDecision.Type getDecisionType()

getDelayNanos

@CheckReturnValue
long getDelayNanos()

Returns:

The delay in nanoseconds, can be negative, if delay value is not decided. negative value can be returned only by a Partial retry predicate.

getResult

@CheckReturnValue
 @Nullable
Either<Exception,T> getResult()

getNewCallable

@CheckReturnValue
 @Nonnull
C getNewCallable()