Class CircuitBreakerProxy

    • Constructor Detail

      • CircuitBreakerProxy

        public CircuitBreakerProxy​(ActorRef target,
                                   int maxFailures,
                                   Timeout callTimeout,
                                   Timeout resetTimeout,
                                   scala.Option<ActorRef> circuitEventListener,
                                   scala.Function1<java.lang.Object,​java.lang.Object> failureDetector,
                                   scala.Function1<CircuitBreakerProxy.CircuitOpenFailure,​java.lang.Object> failureMap)
        Deprecated.
    • Method Detail

      • props

        public static Props props​(ActorRef target,
                                  int maxFailures,
                                  Timeout callTimeout,
                                  Timeout resetTimeout,
                                  scala.Option<ActorRef> circuitEventListener,
                                  scala.Function1<java.lang.Object,​java.lang.Object> failureDetector,
                                  scala.Function1<CircuitBreakerProxy.CircuitOpenFailure,​java.lang.Object> failureMap)
        Deprecated.
        Creates an circuit breaker actor proxying a target actor intended for request-reply interactions. It is possible to send messages through this proxy without expecting a response wrapping them into a CircuitBreakerProxy.TellOnly or a CircuitBreakerProxy.Passthrough the difference between the two being that a message wrapped into a CircuitBreakerProxy.Passthrough is going to be forwarded even when the circuit is open (e.g. if you need to terminate the target and proxy actors sending a PoisonPill message)

        The circuit breaker implements the same state machine documented in CircuitBreaker

        Parameters:
        target - the actor to proxy
        maxFailures - maximum number of failures before opening the circuit
        callTimeout - timeout before considering the ongoing call a failure
        resetTimeout - time after which the channel will be closed after entering the open state
        circuitEventListener - an actor that will receive a series of messages of type CircuitBreakerProxy.CircuitBreakerEvent (optional)
        failureDetector - function to detect if a message received from the target actor as a response from the request represents a failure
        failureMap - function to map a failure into a response message. The failing response message is wrapped into a CircuitBreakerProxy.CircuitOpenFailure object
        Returns:
        (undocumented)
      • sender

        public static final ActorRef sender()
        Deprecated.
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
        Deprecated.
      • aroundPreStart

        protected static void aroundPreStart()
        Deprecated.
      • aroundPostStop

        protected static void aroundPostStop()
        Deprecated.
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
        Deprecated.
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
        Deprecated.
      • preStart

        public static void preStart()
                             throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
                               throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
                                throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
        Deprecated.
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
        Deprecated.
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
        Deprecated.
      • listenerManagement

        protected static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> listenerManagement()
        Deprecated.
      • gossip

        protected static void gossip​(java.lang.Object msg,
                                     ActorRef sender)
        Deprecated.
      • gossip$default$2

        protected static ActorRef gossip$default$2​(java.lang.Object msg)
        Deprecated.
      • when

        public static final void when​(S stateName,
                                      scala.concurrent.duration.FiniteDuration stateTimeout,
                                      scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> stateFunction)
        Deprecated.
      • when$default$2

        public static final scala.concurrent.duration.FiniteDuration when$default$2()
        Deprecated.
      • startWith

        public static final void startWith​(S stateName,
                                           D stateData,
                                           scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
        Deprecated.
      • startWith$default$3

        public static final scala.Option<scala.concurrent.duration.FiniteDuration> startWith$default$3()
        Deprecated.
      • stay

        public static final FSM.State<S,​D> stay()
        Deprecated.
      • stop

        public static final FSM.State<S,​D> stop()
        Deprecated.
      • stop

        public static final FSM.State<S,​D> stop​(FSM.Reason reason,
                                                      D stateData)
        Deprecated.
      • setTimer

        public static final void setTimer​(java.lang.String name,
                                          java.lang.Object msg,
                                          scala.concurrent.duration.FiniteDuration timeout,
                                          boolean repeat)
        Deprecated.
      • setTimer$default$4

        public static final boolean setTimer$default$4()
        Deprecated.
      • cancelTimer

        public static final void cancelTimer​(java.lang.String name)
        Deprecated.
      • isTimerActive

        public static final boolean isTimerActive​(java.lang.String name)
        Deprecated.
      • setStateTimeout

        public static final void setStateTimeout​(S state,
                                                 scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
        Deprecated.
      • isStateTimerActive

        public static final boolean isStateTimerActive()
        Deprecated.
      • onTransition

        public static final void onTransition​(scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit> transitionHandler)
        Deprecated.
      • total2pf

        public static final scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit> total2pf​(scala.Function2<S,​S,​scala.runtime.BoxedUnit> transitionHandler)
        Deprecated.
      • onTermination

        public static final void onTermination​(scala.PartialFunction<FSM.StopEvent<S,​D>,​scala.runtime.BoxedUnit> terminationHandler)
        Deprecated.
      • whenUnhandled

        public static final void whenUnhandled​(scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> stateFunction)
        Deprecated.
      • initialize

        public static final void initialize()
        Deprecated.
      • stateName

        public static final S stateName()
        Deprecated.
      • stateData

        public static final D stateData()
        Deprecated.
      • nextStateData

        public static final D nextStateData()
        Deprecated.
      • debugEvent

        public static boolean debugEvent()
        Deprecated.
      • akka$actor$FSM$$currentState

        public static FSM.State<S,​D> akka$actor$FSM$$currentState()
        Deprecated.
      • akka$actor$FSM$$currentState_$eq

        public static void akka$actor$FSM$$currentState_$eq​(FSM.State<S,​D> x$1)
        Deprecated.
      • akka$actor$FSM$$timeoutFuture

        public static scala.Option<Cancellable> akka$actor$FSM$$timeoutFuture()
        Deprecated.
      • akka$actor$FSM$$timeoutFuture_$eq

        public static void akka$actor$FSM$$timeoutFuture_$eq​(scala.Option<Cancellable> x$1)
        Deprecated.
      • akka$actor$FSM$$nextState

        public static FSM.State<S,​D> akka$actor$FSM$$nextState()
        Deprecated.
      • akka$actor$FSM$$nextState_$eq

        public static void akka$actor$FSM$$nextState_$eq​(FSM.State<S,​D> x$1)
        Deprecated.
      • akka$actor$FSM$$generation

        public static long akka$actor$FSM$$generation()
        Deprecated.
      • akka$actor$FSM$$generation_$eq

        public static void akka$actor$FSM$$generation_$eq​(long x$1)
        Deprecated.
      • akka$actor$FSM$$timers

        public static scala.collection.mutable.Map<java.lang.String,​FSM.Timer> akka$actor$FSM$$timers()
        Deprecated.
      • akka$actor$FSM$$timerGen

        public static scala.collection.Iterator<java.lang.Object> akka$actor$FSM$$timerGen()
        Deprecated.
      • akka$actor$FSM$$stateFunctions

        public static scala.collection.mutable.Map<S,​scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>>> akka$actor$FSM$$stateFunctions()
        Deprecated.
      • akka$actor$FSM$$stateTimeouts

        public static scala.collection.mutable.Map<S,​scala.Option<scala.concurrent.duration.FiniteDuration>> akka$actor$FSM$$stateTimeouts()
        Deprecated.
      • akka$actor$FSM$$handleEventDefault

        public static scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> akka$actor$FSM$$handleEventDefault()
        Deprecated.
      • akka$actor$FSM$$handleEvent

        public static scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> akka$actor$FSM$$handleEvent()
        Deprecated.
      • akka$actor$FSM$$handleEvent_$eq

        public static void akka$actor$FSM$$handleEvent_$eq​(scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> x$1)
        Deprecated.
      • akka$actor$FSM$$terminateEvent

        public static scala.PartialFunction<FSM.StopEvent<S,​D>,​scala.runtime.BoxedUnit> akka$actor$FSM$$terminateEvent()
        Deprecated.
      • akka$actor$FSM$$terminateEvent_$eq

        public static void akka$actor$FSM$$terminateEvent_$eq​(scala.PartialFunction<FSM.StopEvent<S,​D>,​scala.runtime.BoxedUnit> x$1)
        Deprecated.
      • akka$actor$FSM$$transitionEvent

        public static scala.collection.immutable.List<scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit>> akka$actor$FSM$$transitionEvent()
        Deprecated.
      • akka$actor$FSM$$transitionEvent_$eq

        public static void akka$actor$FSM$$transitionEvent_$eq​(scala.collection.immutable.List<scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit>> x$1)
        Deprecated.
      • receive

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Deprecated.
      • processEvent

        public static void processEvent​(FSM.Event<D> event,
                                        java.lang.Object source)
        Deprecated.
      • applyState

        public static void applyState​(FSM.State<S,​D> nextState)
        Deprecated.
      • makeTransition

        public static void makeTransition​(FSM.State<S,​D> nextState)
        Deprecated.
      • postStop

        public static void postStop()
        Deprecated.
      • logTermination

        protected static void logTermination​(FSM.Reason reason)
        Deprecated.
      • akka$actor$FSM$_setter_$$minus$greater_$eq

        protected abstract static void akka$actor$FSM$_setter_$$minus$greater_$eq​(FSM.$minus$greater$ x$1)
        Deprecated.
      • akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq​(scala.collection.mutable.Map<java.lang.String,​FSM.Timer> x$1)
        Deprecated.
      • akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq​(scala.collection.Iterator<java.lang.Object> x$1)
        Deprecated.
      • akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq​(scala.collection.mutable.Map<S,​scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>>> x$1)
        Deprecated.
      • akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq​(scala.collection.mutable.Map<S,​scala.Option<scala.concurrent.duration.FiniteDuration>> x$1)
        Deprecated.
      • akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq​(scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> x$1)
        Deprecated.
      • context

        public ActorContext context()
        Deprecated.
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Deprecated.
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Deprecated.
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Deprecated.
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)