public class ServerFSM extends java.lang.Object implements akka.actor.Actor, akka.actor.LoggingFSM<ServerFSM.State,scala.Option<akka.actor.ActorRef>>
Hello
message (which is needed for all subsequent
node name translations).
In the Ready state, messages from the client are forwarded to the controller
and Send
requests are sent, but the latter is
treated specially: all client operations are to be confirmed by a
Done
message, and there can be only one such
request outstanding at a given time (i.e. a Send fails if the previous has
not yet been acknowledged).
INTERNAL API.
Modifier and Type | Class and Description |
---|---|
static class |
ServerFSM.Initial$ |
static class |
ServerFSM.Ready$ |
static interface |
ServerFSM.State |
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.SilentState<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 |
---|
ServerFSM(akka.actor.ActorRef controller,
org.jboss.netty.channel.Channel channel) |
Modifier and Type | Method and Description |
---|---|
org.jboss.netty.channel.Channel |
channel() |
akka.actor.ActorRef |
controller() |
RoleName |
roleName() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$events_$eq, akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$states_$eq, akka$actor$LoggingFSM$_setter_$debugEvent_$eq, akka$actor$LoggingFSM$$events, akka$actor$LoggingFSM$$full_$eq, akka$actor$LoggingFSM$$full, akka$actor$LoggingFSM$$pos_$eq, akka$actor$LoggingFSM$$pos, akka$actor$LoggingFSM$$states, debugEvent, getLog, logDepth, processEvent
$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$$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, Event, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, 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 ServerFSM(akka.actor.ActorRef controller, org.jboss.netty.channel.Channel channel)
public akka.actor.ActorRef controller()
public org.jboss.netty.channel.Channel channel()
public RoleName roleName()