Package akka.contrib.circuitbreaker
Class Implicits
- java.lang.Object
-
- akka.contrib.circuitbreaker.Implicits
-
public class Implicits extends java.lang.Object
Deprecated.Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.Import this implicit to enable the methodsfailForOpenCircuit
andfailForOpenCircuitWith
toFuture
convertingCircuitBreakerProxy.CircuitOpenFailure
into a failure caused either by anOpenCircuitException
or by an exception built with the given exception builder
-
-
Constructor Summary
Constructors Constructor Description Implicits()
Deprecated.
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static AskeableWithCircuitBreakerActor
askWithCircuitBreaker(ActorRef actorRef)
Deprecated.Import this implicit method to get an extended versions of theask
pattern forActorRef
andActorSelection
convertingCircuitBreakerProxy.CircuitOpenFailure
into a failure caused by anOpenCircuitException
static scala.concurrent.Future<java.lang.Object>
askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, ActorRef sender, scala.concurrent.ExecutionContext executionContext, Timeout timeout)
Deprecated.Wraps theask
method inAskSupport
method to convert failures connected to the circuit breaker being in open statestatic scala.concurrent.Future<java.lang.Object>
askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, scala.concurrent.ExecutionContext executionContext, Timeout timeout)
Deprecated.Wraps theask
method inAskSupport
method to convertCircuitBreakerProxy.CircuitOpenFailure
responses into a failure response caused by anOpenCircuitException
static CircuitBreakerAwareFuture
futureExtensions(scala.concurrent.Future<java.lang.Object> future)
Deprecated.
-
-
-
Method Detail
-
futureExtensions
public static CircuitBreakerAwareFuture futureExtensions(scala.concurrent.Future<java.lang.Object> future)
Deprecated.
-
askWithCircuitBreaker
public static AskeableWithCircuitBreakerActor askWithCircuitBreaker(ActorRef actorRef)
Deprecated.Import this implicit method to get an extended versions of theask
pattern forActorRef
andActorSelection
convertingCircuitBreakerProxy.CircuitOpenFailure
into a failure caused by anOpenCircuitException
- Parameters:
actorRef
- (undocumented)- Returns:
- (undocumented)
-
askWithCircuitBreaker
public static scala.concurrent.Future<java.lang.Object> askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, scala.concurrent.ExecutionContext executionContext, Timeout timeout) throws OpenCircuitException
Deprecated.Wraps theask
method inAskSupport
method to convertCircuitBreakerProxy.CircuitOpenFailure
responses into a failure response caused by anOpenCircuitException
- Parameters:
circuitBreakerProxy
- (undocumented)message
- (undocumented)executionContext
- (undocumented)timeout
- (undocumented)- Returns:
- (undocumented)
- Throws:
OpenCircuitException
-
askWithCircuitBreaker
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
Deprecated.Wraps theask
method inAskSupport
method to convert failures connected to the circuit breaker being in open state- Parameters:
circuitBreakerProxy
- (undocumented)message
- (undocumented)sender
- (undocumented)executionContext
- (undocumented)timeout
- (undocumented)- Returns:
- (undocumented)
- Throws:
OpenCircuitException
-
-