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
- 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
askmethod in akka.pattern.AskSupport method to convert failures connected to the circuit breaker being in open stateWraps the
askmethod 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
askmethod 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
askmethod 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
askpattern 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
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
implicit
def
futureExtensions(future: Future[Any]): CircuitBreakerAwareFuture
Import this implicit to enable the methods
failForOpenCircuitandfailForOpenCircuitWithto 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
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )