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

Field Summary

Fields

Modifier and Type	Field and Description
static Implicits$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Implicits$()

Method Summary

Modifier and Type	Method and Description
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
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
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
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

Field Detail

MODULE$

public static final Implicits$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Implicits$

public Implicits$()

Method Detail

futureExtensions

public 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 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 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 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