Class FallbackExecutor<R>

java.lang.Object

dev.failsafe.spi.PolicyExecutor<R>

dev.failsafe.internal.FallbackExecutor<R>

Type Parameters:

R - result type

public class FallbackExecutor<R>
extends PolicyExecutor<R>

A PolicyExecutor that handles failures according to a Fallback.

Field Summary

Fields

Modifier and Type	Field	Description
private final FallbackConfig<R>	config
private final EventHandler<R>	failedAttemptHandler
private final FallbackImpl<R>	fallback

Constructor Summary

Constructors

Constructor	Description
FallbackExecutor(FallbackImpl<R> fallback, 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, applying a fallback if it fails, and calling 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.

Methods inherited from class PolicyExecutor

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

Methods inherited from class Object

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

Field Details

fallback

private final FallbackImpl<R> fallback

config

private final FallbackConfig<R> config

failedAttemptHandler

private final EventHandler<R> failedAttemptHandler

Constructor Details

FallbackExecutor

public FallbackExecutor(FallbackImpl<R> fallback,
 int policyIndex)

Method Details

apply

public 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, applying a fallback if it fails, and calling 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)

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

Overrides:

applyAsync in class PolicyExecutor<R>