Package akka.contrib.circuitbreaker
Class CircuitBreakerProxy
- java.lang.Object
-
- akka.contrib.circuitbreaker.CircuitBreakerProxy
-
- All Implemented Interfaces:
Actor
,ActorLogging
,FSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
,Listeners
public final class CircuitBreakerProxy extends java.lang.Object implements Actor, ActorLogging, FSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
Deprecated.Use akka.pattern.CircuitBreaker + ask instead. Since 2.5.0.Creates the props for aCircuitBreakerProxy
proxying the given targetparam: target the target actor ref
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
Nested classes/interfaces inherited from interface akka.actor.FSM
FSM.$minus$greater$, FSM.CurrentState<S>, FSM.CurrentState$, FSM.Event<D>, FSM.Event$, FSM.Failure, FSM.Failure$, FSM.LogEntry<S,D>, FSM.LogEntry$, FSM.Normal$, FSM.NullFunction$, FSM.Reason, FSM.Shutdown$, FSM.SilentState<S,D>, FSM.State<S,D>, FSM.State$, FSM.StateTimeout$, FSM.StopEvent<S,D>, FSM.StopEvent$, FSM.SubscribeTransitionCallBack, FSM.SubscribeTransitionCallBack$, FSM.Timer, FSM.Timer$, FSM.TransformHelper, FSM.Transition<S>, FSM.Transition$, FSM.UnsubscribeTransitionCallBack, FSM.UnsubscribeTransitionCallBack$
-
-
Constructor Summary
Constructors Constructor Description 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 Summary
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.actor.FSM
applyState, cancelTimer, currentState_$eq, debugEvent, generation_$eq, handleEvent_$eq, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState_$eq, nextStateData, onTermination, onTransition, postStop, processEvent, processMsg, receive, register, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, stay, stop, stop, stop, super$postStop, terminate, terminateEvent_$eq, timeoutFuture_$eq, total2pf, transform, transitionEvent_$eq, when, when$default$2, whenUnhandled
-
Methods inherited from interface akka.routing.Listeners
gossip, gossip$default$2, listenerManagement
-
-
-
-
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.
-
Event
public FSM.Event$ Event()
Deprecated.- Specified by:
Event
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
-
StopEvent
public FSM.StopEvent$ StopEvent()
Deprecated.- Specified by:
StopEvent
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
-
$minus$greater
public FSM.$minus$greater$ $minus$greater()
Deprecated.Description copied from interface:FSM
This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.- Specified by:
$minus$greater
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
- Returns:
- (undocumented)
-
StateTimeout
public FSM.StateTimeout$ StateTimeout()
Deprecated.Description copied from interface:FSM
This case object is received in case of a state timeout.- Specified by:
StateTimeout
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
- Returns:
- (undocumented)
-
akka$actor$FSM$_setter_$Event_$eq
protected void akka$actor$FSM$_setter_$Event_$eq(FSM.Event$ x$1)
Deprecated.- Specified by:
akka$actor$FSM$_setter_$Event_$eq
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
-
akka$actor$FSM$_setter_$StopEvent_$eq
protected void akka$actor$FSM$_setter_$StopEvent_$eq(FSM.StopEvent$ x$1)
Deprecated.- Specified by:
akka$actor$FSM$_setter_$StopEvent_$eq
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
-
akka$actor$FSM$_setter_$StateTimeout_$eq
protected void akka$actor$FSM$_setter_$StateTimeout_$eq(FSM.StateTimeout$ x$1)
Deprecated.Description copied from interface:FSM
This case object is received in case of a state timeout.- Specified by:
akka$actor$FSM$_setter_$StateTimeout_$eq
in interfaceFSM<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>
- Parameters:
x$1
- (undocumented)
-
listeners
protected java.util.Set<ActorRef> listeners()
Deprecated.
-
akka$routing$Listeners$_setter_$listeners_$eq
protected void akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
Deprecated.- Specified by:
akka$routing$Listeners$_setter_$listeners_$eq
in interfaceListeners
-
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 asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
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
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Deprecated.- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
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 interfaceActor
- Parameters:
x$1
- (undocumented)
-
callSucceededHandling
public scala.PartialFunction<FSM.Event<CircuitBreakerProxy.CircuitBreakerStateData>,FSM.State<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>> callSucceededHandling()
Deprecated.
-
passthroughHandling
public scala.PartialFunction<FSM.Event<CircuitBreakerProxy.CircuitBreakerStateData>,FSM.State<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>> passthroughHandling()
Deprecated.
-
targetTerminationHandling
public scala.PartialFunction<FSM.Event<CircuitBreakerProxy.CircuitBreakerStateData>,FSM.State<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>> targetTerminationHandling()
Deprecated.
-
commonStateHandling
public scala.PartialFunction<FSM.Event<CircuitBreakerProxy.CircuitBreakerStateData>,FSM.State<CircuitBreakerProxy.CircuitBreakerState,CircuitBreakerProxy.CircuitBreakerStateData>> commonStateHandling()
Deprecated.
-
forwardRequest
public void forwardRequest(java.lang.Object message, ActorRef currentSender, CircuitBreakerProxy.CircuitBreakerStateData state, LoggingAdapter log)
Deprecated.
-
-