Package dev.failsafe.internal

Class BulkheadExecutor<R>

java.lang.Object

dev.failsafe.spi.PolicyExecutor<R>

dev.failsafe.internal.BulkheadExecutor<R>

Type Parameters:

R - result type

public class BulkheadExecutor<R>
extends PolicyExecutor<R>

A PolicyExecutor that handles failures according to a Bulkhead.

Field Summary

Fields

Modifier and Type	Field	Description
private BulkheadImpl<R>	bulkhead
private java.time.Duration	maxWaitTime

Constructor Summary

Constructors

Constructor	Description
BulkheadExecutor(BulkheadImpl<R> bulkhead, int policyIndex)

Method Summary

Modifier and Type	Method	Description
protected 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.
void	onSuccess(ExecutionResult<R> result)	Performs post-execution handling for a result that is considered a success according to PolicyExecutor.isFailure(ExecutionResult).
protected ExecutionResult<R>	preExecute()	Called before execution to return an alternative result or exception such as if execution is not allowed or needed.
protected java.util.concurrent.CompletableFuture<ExecutionResult<R>>	preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)	Called before an async execution to return an alternative result or exception such as if execution is not allowed or needed.

Methods inherited from class dev.failsafe.spi.PolicyExecutor

apply, applyAsync, getPolicyIndex, isFailure, onFailureAsync, postExecute, postExecuteAsync

Methods inherited from class java.lang.Object

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

Field Detail

bulkhead

private final BulkheadImpl<R> bulkhead

maxWaitTime

private final java.time.Duration maxWaitTime

Constructor Detail

BulkheadExecutor

public BulkheadExecutor(BulkheadImpl<R> bulkhead,
                        int policyIndex)

Method Detail

preExecute

protected ExecutionResult<R> preExecute()

Description copied from class: PolicyExecutor

Called before execution to return an alternative result or exception such as if execution is not allowed or needed.

Overrides:

preExecute in class PolicyExecutor<R>

preExecuteAsync

protected java.util.concurrent.CompletableFuture<ExecutionResult<R>> preExecuteAsync(Scheduler scheduler,
                                                                                     FailsafeFuture<R> future)

Description copied from class: PolicyExecutor

Called before an async execution to return an alternative result or exception such as if execution is not allowed or needed. Returns null if pre execution is not performed. If the resulting future is completed with a non-result, then execution and post-execution should still be performed. If the resulting future is completed with null, then the execution is assumed to have been cancelled.

Overrides:

preExecuteAsync in class PolicyExecutor<R>

onSuccess

public void onSuccess(ExecutionResult<R> result)

Description copied from class: PolicyExecutor

Performs post-execution handling for a result that is considered a success according to PolicyExecutor.isFailure(ExecutionResult).

Overrides:

onSuccess in class PolicyExecutor<R>

onFailure

protected 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>