akka.remote.testconductor
Class ServerFSM
java.lang.Object
akka.remote.testconductor.ServerFSM
- All Implemented Interfaces:
- Actor, ActorLogging, FSM<ServerFSM.State,scala.Option<ActorRef>>, LoggingFSM<ServerFSM.State,scala.Option<ActorRef>>, Listeners
public class ServerFSM
- extends java.lang.Object
- implements Actor, LoggingFSM<ServerFSM.State,scala.Option<ActorRef>>
The server part of each client connection is represented by a ServerFSM.
The Initial state handles reception of the new client’s
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 akka.remote.testconductor.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.
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.State$, FSM.StateTimeout$, FSM.StopEvent<S,D>, FSM.StopEvent$, FSM.SubscribeTransitionCallBack, FSM.SubscribeTransitionCallBack$, FSM.TimeoutMarker, FSM.TimeoutMarker$, FSM.Timer, FSM.Timer$, FSM.TransformHelper, FSM.Transition<S>, FSM.Transition$, FSM.UnsubscribeTransitionCallBack, FSM.UnsubscribeTransitionCallBack$ |
Constructor Summary |
ServerFSM(ActorRef controller,
org.jboss.netty.channel.Channel channel)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.actor.FSM |
applyState, cancelTimer, currentState, Event, generation, handleEvent, handleEventDefault, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState, nextStateData, onTermination, onTransition, processMsg, register, setStateTimeout, setTimer, startWith, stateData, stateFunctions, stateName, StateTimeout, stateTimeouts, stay, stop, stop, stop, StopEvent, terminate, terminateEvent, timeoutFuture, timerGen, timers, total2pf, transform, transitionEvent, when, whenUnhandled |
Methods inherited from interface akka.actor.Actor |
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled |
ServerFSM
public ServerFSM(ActorRef controller,
org.jboss.netty.channel.Channel channel)
controller
public ActorRef controller()
channel
public org.jboss.netty.channel.Channel channel()
roleName
public RoleName roleName()