Class Implicits


  • public class Implicits
    extends java.lang.Object
    Deprecated.
    Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.
    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
    • Constructor Detail

      • Implicits

        public Implicits()
        Deprecated.
    • Method Detail

      • futureExtensions

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

        public static scala.concurrent.Future<java.lang.Object> askWithCircuitBreaker​(ActorRef circuitBreakerProxy,
                                                                                      java.lang.Object message,
                                                                                      scala.concurrent.ExecutionContext executionContext,
                                                                                      Timeout timeout)
                                                                               throws OpenCircuitException
        Deprecated.
        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
        Deprecated.
        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