akka.contrib.circuitbreaker

Class AskeableWithCircuitBreakerActorSelection

java.lang.Object

scala.AnyVal

akka.contrib.circuitbreaker.AskeableWithCircuitBreakerActorSelection

public final class AskeableWithCircuitBreakerActorSelection
extends scala.AnyVal

Constructor Summary

Constructors

Constructor and Description
AskeableWithCircuitBreakerActorSelection(ActorSelection actorSelection)

Method Summary

Modifier and Type	Method and Description
ActorSelection	actorSelection()
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

AskeableWithCircuitBreakerActorSelection

public AskeableWithCircuitBreakerActorSelection(ActorSelection actorSelection)

Method Detail

getClass

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

actorSelection

public ActorSelection actorSelection()

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)