Class RetryPolicyExecutor<R>

java.lang.Object

dev.failsafe.spi.PolicyExecutor<R>

dev.failsafe.internal.RetryPolicyExecutor<R>

Type Parameters:

R - result type

public class RetryPolicyExecutor<R>
extends PolicyExecutor<R>

A PolicyExecutor that handles failures according to a RetryPolicy.

Author:

Jonathan Halterman

Constructor Summary

Constructors

Constructor	Description
RetryPolicyExecutor(RetryPolicyImpl<R> retryPolicy, int policyIndex)

Method Summary

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>, ExecutionResult<R>>	apply(Function<SyncExecutionInternal<R>, ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>>	applyAsync(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
Object	handleAsync(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef)
ExecutionResult<R>	onFailure(ExecutionContext<R> context, ExecutionResult<R> result)	Performs post-execution handling for a result that is considered a failure according to PolicyExecutor.isFailure(ExecutionResult), possibly creating a new result, else returning the original result.
CompletableFuture<ExecutionResult<R>>	onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Defaults async executions to not be complete until says they are.

Methods inherited from class PolicyExecutor

getPolicyIndex, isFailure, onSuccess, postExecute, postExecuteAsync, preExecute, preExecuteAsync

Methods inherited from class Object

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

Constructor Details

RetryPolicyExecutor

public RetryPolicyExecutor(RetryPolicyImpl<R> retryPolicy,
 int policyIndex)

Method Details

apply

public Function<SyncExecutionInternal<R>, ExecutionResult<R>> apply(Function<SyncExecutionInternal<R>, ExecutionResult<R>> innerFn,
 Scheduler scheduler)

Description copied from class: PolicyExecutor

Performs an execution by calling pre-execute else calling the supplier and doing a post-execute.

Overrides:

apply in class PolicyExecutor<R>

applyAsync

public Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> applyAsync(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn,
 Scheduler scheduler,
 FailsafeFuture<R> future)

Description copied from class: PolicyExecutor

Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute. Implementors must handle a null result from a supplier, which indicates that an async execution has occurred, that a result will be recorded separately, and that postExecute handling should not be performed.

Overrides:

applyAsync in class PolicyExecutor<R>

handleAsync

public Object handleAsync(AsyncExecutionInternal<R> execution,
 Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn,
 Scheduler scheduler,
 FailsafeFuture<R> future,
 CompletableFuture<ExecutionResult<R>> promise,
 AtomicReference<ExecutionResult<R>> previousResultRef)

onFailure

public ExecutionResult<R> onFailure(ExecutionContext<R> context,
 ExecutionResult<R> result)

Description copied from class: PolicyExecutor

Performs post-execution handling for a result that is considered a failure according to PolicyExecutor.isFailure(ExecutionResult), possibly creating a new result, else returning the original result.

Overrides:

onFailure in class PolicyExecutor<R>

onFailureAsync

public CompletableFuture<ExecutionResult<R>> onFailureAsync(ExecutionContext<R> context,
 ExecutionResult<R> result,
 Scheduler scheduler,
 FailsafeFuture<R> future)

Defaults async executions to not be complete until says they are.

Overrides:

onFailureAsync in class PolicyExecutor<R>