Class Implicits$


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

      • MODULE$

        public static final Implicits$ MODULE$
        Deprecated.
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Implicits$

        public Implicits$()
        Deprecated.
    • Method Detail

      • futureExtensions

        public CircuitBreakerAwareFuture futureExtensions​(scala.concurrent.Future<java.lang.Object> future)
        Deprecated.
        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 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