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
-
-
Field Summary
Fields Modifier and Type Field Description static Implicits$
MODULE$
Deprecated.Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description Implicits$()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description 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
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 statescala.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
CircuitBreakerAwareFuture
futureExtensions(scala.concurrent.Future<java.lang.Object> future)
Deprecated.
-
-
-
Field Detail
-
MODULE$
public static final Implicits$ MODULE$
Deprecated.Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
futureExtensions
public CircuitBreakerAwareFuture futureExtensions(scala.concurrent.Future<java.lang.Object> future)
Deprecated.
-
askWithCircuitBreaker
public 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 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 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
-
-