akka.contrib.circuitbreaker

Class Implicits

java.lang.Object

akka.contrib.circuitbreaker.Implicits

public class Implicits
extends java.lang.Object

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 CircuitBreakerProxy.CircuitOpenFailure response

Constructor Summary

Constructors

Constructor and Description
Implicits()

Method Summary

Modifier and Type	Method and Description
static AskeableWithCircuitBreakerActor	askWithCircuitBreaker(ActorRef actorRef) Import this implicit method to get an extended versions of the ask pattern for ActorRef and ActorSelection converting CircuitBreakerProxy.CircuitOpenFailure into a failure caused by an OpenCircuitException
static scala.concurrent.Future<java.lang.Object>	askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, ActorRef sender, scala.concurrent.ExecutionContext executionContext, Timeout timeout) Wraps the ask method in AskSupport method to convert failures connected to the circuit breaker being in open state
static scala.concurrent.Future<java.lang.Object>	askWithCircuitBreaker(ActorRef circuitBreakerProxy, java.lang.Object message, scala.concurrent.ExecutionContext executionContext, Timeout timeout) Wraps the ask method in AskSupport method to convert CircuitBreakerProxy.CircuitOpenFailure responses into a failure response caused by an OpenCircuitException
static CircuitBreakerAwareFuture	futureExtensions(scala.concurrent.Future<java.lang.Object> future) Import this implicit to enable the methods failForOpenCircuit and failForOpenCircuitWith to Future converting CircuitBreakerProxy.CircuitOpenFailure into a failure caused either by an OpenCircuitException or by an exception built with the given exception builder

Methods inherited from class java.lang.Object

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

Constructor Detail

Implicits

public Implicits()

Method Detail

futureExtensions

public static CircuitBreakerAwareFuture futureExtensions(scala.concurrent.Future<java.lang.Object> future)

Import this implicit to enable the methods failForOpenCircuit and failForOpenCircuitWith to Future converting CircuitBreakerProxy.CircuitOpenFailure into a failure caused either by an OpenCircuitException or by an exception built with the given exception builder

Parameters:

future - (undocumented)

Returns:

(undocumented)

askWithCircuitBreaker

public static AskeableWithCircuitBreakerActor askWithCircuitBreaker(ActorRef actorRef)

Import this implicit method to get an extended versions of the ask pattern for ActorRef and ActorSelection converting CircuitBreakerProxy.CircuitOpenFailure into a failure caused by an OpenCircuitException

Parameters:

actorRef - (undocumented)

Returns:

(undocumented)

askWithCircuitBreaker

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

Wraps the ask method in AskSupport method to convert CircuitBreakerProxy.CircuitOpenFailure responses into a failure response caused by an OpenCircuitException

Parameters:

circuitBreakerProxy - (undocumented)

message - (undocumented)

executionContext - (undocumented)

timeout - (undocumented)

Returns:

(undocumented)

Throws:

OpenCircuitException

askWithCircuitBreaker

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

Wraps the ask method in AskSupport 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