akka.contrib.circuitbreaker

Class AskeableWithCircuitBreakerActor

java.lang.Object

scala.AnyVal

akka.contrib.circuitbreaker.AskeableWithCircuitBreakerActor

public final class AskeableWithCircuitBreakerActor
extends scala.AnyVal

Constructor Summary

Constructors

Constructor and Description
AskeableWithCircuitBreakerActor(ActorRef actorRef)

Method Summary

Modifier and Type	Method and Description
ActorRef	actorRef()
scala.concurrent.Future<java.lang.Object>	askWithCircuitBreaker(java.lang.Object message, scala.concurrent.ExecutionContext executionContext, Timeout timeout, ActorRef sender)
static java.lang.Class<? extends java.lang.Object>	getClass()
scala.concurrent.Future<java.lang.Object>	internalAskWithCircuitBreaker(java.lang.Object message, Timeout timeout, ActorRef sender, scala.concurrent.ExecutionContext executionContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AskeableWithCircuitBreakerActor

public AskeableWithCircuitBreakerActor(ActorRef actorRef)

Method Detail

getClass

public static java.lang.Class<? extends java.lang.Object> getClass()

actorRef

public ActorRef actorRef()

askWithCircuitBreaker

public scala.concurrent.Future<java.lang.Object> askWithCircuitBreaker(java.lang.Object message,
                                                                       scala.concurrent.ExecutionContext executionContext,
                                                                       Timeout timeout,
                                                                       ActorRef sender)

internalAskWithCircuitBreaker

public scala.concurrent.Future<java.lang.Object> internalAskWithCircuitBreaker(java.lang.Object message,
                                                                               Timeout timeout,
                                                                               ActorRef sender,
                                                                               scala.concurrent.ExecutionContext executionContext)
                                                                        throws OpenCircuitException

Throws:

OpenCircuitException