Package dev.failsafe.internal

Class CircuitBreakerExecutor<R>

java.lang.Object

dev.failsafe.spi.PolicyExecutor<R>

dev.failsafe.internal.CircuitBreakerExecutor<R>

Type Parameters:

R - result type

public class CircuitBreakerExecutor<R>
extends PolicyExecutor<R>

A PolicyExecutor that handles failures according to a CircuitBreaker.

Field Summary

Fields

Modifier and Type	Field	Description
private final CircuitBreakerImpl<R>	circuitBreaker

Constructor Summary

Constructors

Constructor	Description
CircuitBreakerExecutor(CircuitBreakerImpl<R> circuitBreaker, 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.

Methods inherited from class dev.failsafe.spi.PolicyExecutor

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

Methods inherited from class java.lang.Object

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

Field Details

circuitBreaker

private final CircuitBreakerImpl<R> circuitBreaker

Constructor Details

CircuitBreakerExecutor

public CircuitBreakerExecutor(CircuitBreakerImpl<R> circuitBreaker,
 int policyIndex)

Method Details

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>

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>