public class Implicits
extends java.lang.Object
ask/?
with askWithCircuitBreaker
or with an extension method to the
Future
result of an ask
pattern to fail in case of
CircuitBreakerProxy.CircuitOpenFailure
responseConstructor and Description |
---|
Implicits() |
Modifier and Type | Method and Description |
---|---|
static AskeableWithCircuitBreakerActor |
askWithCircuitBreaker(ActorRef actorRef)
Import this implicit method to get an extended versions of the
ask pattern for
ActorRef and ActorSelection converting
CircuitBreakerProxy.CircuitOpenFailure into a failure caused by an
OpenCircuitException |
static scala.concurrent.Future<java.lang.Object> |
askWithCircuitBreaker(ActorRef circuitBreakerProxy,
java.lang.Object message,
ActorRef sender,
scala.concurrent.ExecutionContext executionContext,
Timeout timeout)
Wraps the
ask method in AskSupport method to convert failures connected to the circuit
breaker being in open state |
static scala.concurrent.Future<java.lang.Object> |
askWithCircuitBreaker(ActorRef circuitBreakerProxy,
java.lang.Object message,
scala.concurrent.ExecutionContext executionContext,
Timeout timeout)
Wraps the
ask method in AskSupport method to convert
CircuitBreakerProxy.CircuitOpenFailure responses into a failure response caused
by an OpenCircuitException |
static CircuitBreakerAwareFuture |
futureExtensions(scala.concurrent.Future<java.lang.Object> future)
Import this implicit to enable the methods
failForOpenCircuit and failForOpenCircuitWith
to Future converting
CircuitBreakerProxy.CircuitOpenFailure into a failure caused either by an
OpenCircuitException or by an exception built with the given
exception builder |
public static CircuitBreakerAwareFuture futureExtensions(scala.concurrent.Future<java.lang.Object> future)
failForOpenCircuit
and failForOpenCircuitWith
to Future
converting
CircuitBreakerProxy.CircuitOpenFailure
into a failure caused either by an
OpenCircuitException
or by an exception built with the given
exception builderfuture
- (undocumented)public static AskeableWithCircuitBreakerActor askWithCircuitBreaker(ActorRef actorRef)
ask
pattern for
ActorRef
and ActorSelection
converting
CircuitBreakerProxy.CircuitOpenFailure
into a failure caused by an
OpenCircuitException
actorRef
- (undocumented)public static scala.concurrent.Future<java.lang.Object> askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, scala.concurrent.ExecutionContext executionContext, Timeout timeout) throws OpenCircuitException
ask
method in AskSupport
method to convert
CircuitBreakerProxy.CircuitOpenFailure
responses into a failure response caused
by an OpenCircuitException
circuitBreakerProxy
- (undocumented)message
- (undocumented)executionContext
- (undocumented)timeout
- (undocumented)OpenCircuitException
public static scala.concurrent.Future<java.lang.Object> askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, ActorRef sender, scala.concurrent.ExecutionContext executionContext, Timeout timeout) throws OpenCircuitException
ask
method in AskSupport
method to convert failures connected to the circuit
breaker being in open statecircuitBreakerProxy
- (undocumented)message
- (undocumented)sender
- (undocumented)executionContext
- (undocumented)timeout
- (undocumented)OpenCircuitException