Package io.vertx.circuitbreaker
Interface FailurePolicy<T>
-
- All Superinterfaces:
java.util.function.Predicate<Future<T>>
public interface FailurePolicy<T> extends java.util.function.Predicate<Future<T>>
A failure policy for theCircuitBreaker
.The default policy is to consider an asynchronous result as a failure if
AsyncResult.failed()
returnstrue
. Nevertheless, sometimes this is not good enough. For example, an HTTP Client could return a response, but with an unexpected status code.In this case, a custom failure policy can be configured with
CircuitBreaker.failurePolicy(FailurePolicy)
.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static <U> FailurePolicy<U>
defaultPolicy()
The default policy, which considers an asynchronous result as a failure ifAsyncResult.failed()
returnstrue
.boolean
test(Future<T> future)
Invoked by theCircuitBreaker
when an operation completes.
-
-
-
Method Detail
-
defaultPolicy
static <U> FailurePolicy<U> defaultPolicy()
The default policy, which considers an asynchronous result as a failure ifAsyncResult.failed()
returnstrue
.
-
test
boolean test(Future<T> future)
Invoked by theCircuitBreaker
when an operation completes.- Specified by:
test
in interfacejava.util.function.Predicate<T>
- Parameters:
future
- a completed future- Returns:
true
if the asynchronous result should be considered as a failure,false
otherwise
-
-