public class ConnectionMonitor extends Object implements akka.actor.Actor, akka.actor.FSM<ConnectionMonitor.FsmState,scala.runtime.BoxedUnit>
Modifier and Type | Class and Description |
---|---|
static class |
ConnectionMonitor.ConnectedState$ |
static class |
ConnectionMonitor.ConnectingState$ |
static interface |
ConnectionMonitor.FsmState
An FSM state of the connection monitor.
|
static class |
ConnectionMonitor.Start
Starts the connection monitor.
|
static class |
ConnectionMonitor.Start$ |
static class |
ConnectionMonitor.Stop
Stops the connection monitor.
|
static class |
ConnectionMonitor.Stop$ |
static class |
ConnectionMonitor.StoppedState$ |
akka.actor.FSM.$minus$greater$, akka.actor.FSM.CurrentState<S>, akka.actor.FSM.CurrentState$, akka.actor.FSM.Event<D>, akka.actor.FSM.Event$, akka.actor.FSM.Failure, akka.actor.FSM.Failure$, akka.actor.FSM.LogEntry<S,D>, akka.actor.FSM.LogEntry$, akka.actor.FSM.Normal$, akka.actor.FSM.NullFunction$, akka.actor.FSM.Reason, akka.actor.FSM.Shutdown$, akka.actor.FSM.State<S,D>, akka.actor.FSM.State$, akka.actor.FSM.StateTimeout$, akka.actor.FSM.StopEvent<S,D>, akka.actor.FSM.StopEvent$, akka.actor.FSM.SubscribeTransitionCallBack, akka.actor.FSM.SubscribeTransitionCallBack$, akka.actor.FSM.TimeoutMarker, akka.actor.FSM.TimeoutMarker$, akka.actor.FSM.Timer, akka.actor.FSM.Timer$, akka.actor.FSM.TransformHelper, akka.actor.FSM.Transition<S>, akka.actor.FSM.Transition$, akka.actor.FSM.UnsubscribeTransitionCallBack, akka.actor.FSM.UnsubscribeTransitionCallBack$
Constructor and Description |
---|
ConnectionMonitor() |
Modifier and Type | Method and Description |
---|---|
static akka.actor.FSM.$minus$greater$ |
$minus$greater() |
static void |
applyState(akka.actor.FSM.State<S,D> nextState) |
protected static void |
aroundPostRestart(Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(Throwable reason,
scala.Option<Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive,
Object msg) |
static void |
cancelTimer(String name) |
static scala.concurrent.duration.FiniteDuration |
CONNECT_RETRY_RATE() |
static akka.actor.ActorContext |
context() |
static <T extends ConnectionMonitor> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig)
Creates the properties for the ConnectionMonitor actor.
|
static boolean |
debugEvent() |
static akka.actor.FSM.Event$ |
Event() |
protected static void |
gossip(Object msg,
akka.actor.ActorRef sender) |
protected static akka.actor.ActorRef |
gossip$default$2(Object msg) |
static void |
initialize() |
static boolean |
isStateTimerActive() |
static boolean |
isTimerActive(String name) |
protected static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
listenerManagement() |
protected static Set<akka.actor.ActorRef> |
listeners() |
static akka.event.LoggingAdapter |
log() |
grizzled.slf4j.Logger |
LOG() |
protected static void |
logTermination(akka.actor.FSM.Reason reason) |
static void |
makeTransition(akka.actor.FSM.State<S,D> nextState) |
static D |
nextStateData() |
static void |
onTermination(scala.PartialFunction<akka.actor.FSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler) |
static void |
onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler) |
static void |
postRestart(Throwable reason) |
static void |
postStop() |
static void |
preRestart(Throwable reason,
scala.Option<Object> message) |
static void |
preStart() |
static void |
processEvent(akka.actor.FSM.Event<D> event,
Object source) |
static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
static akka.actor.ActorRef |
self() |
static akka.actor.ActorRef |
sender() |
static void |
setStateTimeout(S state,
scala.Option<scala.concurrent.duration.FiniteDuration> timeout) |
static void |
setTimer(String name,
Object msg,
scala.concurrent.duration.FiniteDuration timeout,
boolean repeat) |
static boolean |
setTimer$default$4() |
static void |
startWith(S stateName,
D stateData,
scala.Option<scala.concurrent.duration.FiniteDuration> timeout) |
static scala.Option<scala.concurrent.duration.FiniteDuration> |
startWith$default$3() |
static D |
stateData() |
static S |
stateName() |
static akka.actor.FSM.StateTimeout$ |
StateTimeout() |
static akka.actor.FSM.State<S,D> |
stay() |
static akka.actor.FSM.State<S,D> |
stop() |
static akka.actor.FSM.State<S,D> |
stop(akka.actor.FSM.Reason reason) |
static akka.actor.FSM.State<S,D> |
stop(akka.actor.FSM.Reason reason,
D stateData) |
static akka.actor.FSM.StopEvent$ |
StopEvent() |
static akka.actor.SupervisorStrategy |
supervisorStrategy() |
static scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> |
total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler) |
static akka.actor.FSM.TransformHelper |
transform(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> func) |
static void |
unhandled(Object message) |
static void |
when(S stateName,
scala.concurrent.duration.FiniteDuration stateTimeout,
scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction) |
static scala.concurrent.duration.FiniteDuration |
when$default$2() |
static void |
whenUnhandled(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$minus$greater, akka$actor$FSM$_setter_$$minus$greater_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq, akka$actor$FSM$_setter_$Event_$eq, akka$actor$FSM$_setter_$StateTimeout_$eq, akka$actor$FSM$_setter_$StopEvent_$eq, akka$actor$FSM$$currentState_$eq, akka$actor$FSM$$currentState, akka$actor$FSM$$generation_$eq, akka$actor$FSM$$generation, akka$actor$FSM$$handleEvent_$eq, akka$actor$FSM$$handleEvent, akka$actor$FSM$$handleEventDefault, akka$actor$FSM$$nextState_$eq, akka$actor$FSM$$nextState, akka$actor$FSM$$stateFunctions, akka$actor$FSM$$stateTimeouts, akka$actor$FSM$$super$postStop, akka$actor$FSM$$terminateEvent_$eq, akka$actor$FSM$$terminateEvent, akka$actor$FSM$$timeoutFuture_$eq, akka$actor$FSM$$timeoutFuture, akka$actor$FSM$$timerGen, akka$actor$FSM$$timers, akka$actor$FSM$$transitionEvent_$eq, akka$actor$FSM$$transitionEvent, applyState, cancelTimer, debugEvent, Event, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, postStop, processEvent, receive, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, StateTimeout, stay, stop, stop, stop, StopEvent, total2pf, transform, when, when$default$2, whenUnhandled
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public static scala.concurrent.duration.FiniteDuration CONNECT_RETRY_RATE()
public static <T extends ConnectionMonitor> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig)
actorClass
- the connection monitor actor classflinkConfig
- the Flink configuration.public static akka.actor.ActorContext context()
public static final akka.actor.ActorRef self()
public static final akka.actor.ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive, Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(Throwable reason, scala.Option<Object> message)
protected static void aroundPostRestart(Throwable reason)
public static akka.actor.SupervisorStrategy supervisorStrategy()
public static void preRestart(Throwable reason, scala.Option<Object> message) throws Exception
Exception
public static void unhandled(Object message)
protected static Set<akka.actor.ActorRef> listeners()
protected static scala.PartialFunction<Object,scala.runtime.BoxedUnit> listenerManagement()
protected static void gossip(Object msg, akka.actor.ActorRef sender)
protected static akka.actor.ActorRef gossip$default$2(Object msg)
public static akka.event.LoggingAdapter log()
public static akka.actor.FSM.Event$ Event()
public static akka.actor.FSM.StopEvent$ StopEvent()
public static akka.actor.FSM.$minus$greater$ $minus$greater()
public static akka.actor.FSM.StateTimeout$ StateTimeout()
public static final void when(S stateName, scala.concurrent.duration.FiniteDuration stateTimeout, scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction)
public static final void startWith(S stateName, D stateData, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final akka.actor.FSM.State<S,D> stay()
public static final akka.actor.FSM.State<S,D> stop()
public static final akka.actor.FSM.State<S,D> stop(akka.actor.FSM.Reason reason)
public static final akka.actor.FSM.State<S,D> stop(akka.actor.FSM.Reason reason, D stateData)
public static final akka.actor.FSM.TransformHelper transform(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> func)
public static final void setTimer(String name, Object msg, scala.concurrent.duration.FiniteDuration timeout, boolean repeat)
public static final void cancelTimer(String name)
public static final boolean isTimerActive(String name)
public static final void setStateTimeout(S state, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final boolean isStateTimerActive()
public static final void onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler)
public static final scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler)
public static final void onTermination(scala.PartialFunction<akka.actor.FSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler)
public static final void whenUnhandled(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction)
public static final void initialize()
public static final S stateName()
public static final D stateData()
public static final D nextStateData()
public static boolean debugEvent()
public static scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
public static void processEvent(akka.actor.FSM.Event<D> event, Object source)
public static void applyState(akka.actor.FSM.State<S,D> nextState)
public static void makeTransition(akka.actor.FSM.State<S,D> nextState)
public static void postStop()
protected static void logTermination(akka.actor.FSM.Reason reason)
public static final scala.concurrent.duration.FiniteDuration when$default$2()
public static final scala.Option<scala.concurrent.duration.FiniteDuration> startWith$default$3()
public static final boolean setTimer$default$4()
public grizzled.slf4j.Logger LOG()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.