object Implicits
Convenience implicit conversions to provide circuit-breaker aware management of the ask pattern,
either directly replacing the ask/?
with askWithCircuitBreaker
or with an extension method to the
Future
result of an ask
pattern to fail in case of
akka.contrib.circuitbreaker.CircuitBreakerProxy.CircuitOpenFailure response
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.0) Use akka.pattern.CircuitBreaker + ask instead
- Source
- askExtensions.scala
- Alphabetic
- By Inheritance
- Implicits
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
askWithCircuitBreaker(circuitBreakerProxy: ActorRef, message: Any, sender: ActorRef)(implicit executionContext: ExecutionContext, timeout: Timeout): Future[Any]
Wraps the
ask
method in akka.pattern.AskSupport method to convert failures connected to the circuit breaker being in open stateWraps the
ask
method in akka.pattern.AskSupport method to convert failures connected to the circuit breaker being in open state- Annotations
- @throws( ... )
-
def
askWithCircuitBreaker(circuitBreakerProxy: ActorRef, message: Any)(implicit executionContext: ExecutionContext, timeout: Timeout): Future[Any]
Wraps the
ask
method in akka.pattern.AskSupport method to convert akka.contrib.circuitbreaker.CircuitBreakerProxy.CircuitOpenFailure responses into a failure response caused by an akka.contrib.circuitbreaker.OpenCircuitExceptionWraps the
ask
method in akka.pattern.AskSupport method to convert akka.contrib.circuitbreaker.CircuitBreakerProxy.CircuitOpenFailure responses into a failure response caused by an akka.contrib.circuitbreaker.OpenCircuitException- Annotations
- @throws( ... )
-
implicit
def
askWithCircuitBreaker(actorRef: ActorRef): AskeableWithCircuitBreakerActor
Import this implicit method to get an extended versions of the
ask
pattern for akka.actor.ActorRef and akka.actor.ActorSelection converting akka.contrib.circuitbreaker.CircuitBreakerProxy.CircuitOpenFailure into a failure caused by an akka.contrib.circuitbreaker.OpenCircuitException -
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
implicit
def
futureExtensions(future: Future[Any]): CircuitBreakerAwareFuture
Import this implicit to enable the methods
failForOpenCircuit
andfailForOpenCircuitWith
to scala.concurrent.Future converting akka.contrib.circuitbreaker.CircuitBreakerProxy.CircuitOpenFailure into a failure caused either by an akka.contrib.circuitbreaker.OpenCircuitException or by an exception built with the given exception builder -
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )