Package akka.remote.testconductor
Class ClientFSM
- java.lang.Object
-
- akka.remote.testconductor.ClientFSM
-
- All Implemented Interfaces:
Actor
,ActorLogging
,FSM<ClientFSM.State,ClientFSM.Data>
,LoggingFSM<ClientFSM.State,ClientFSM.Data>
,RequiresMessageQueue<UnboundedMessageQueueSemantics>
,Listeners
public class ClientFSM extends java.lang.Object implements Actor, LoggingFSM<ClientFSM.State,ClientFSM.Data>, RequiresMessageQueue<UnboundedMessageQueueSemantics>
This is the controlling entity on thePlayer
side: in a first step it registers itself with a symbolic name and its remote address at theController
, then waits for theDone
message which signals that all other expected test participants have done the same. After that, it will pass barrier requests to and from the coordinator and react to theConductor
’s requests for failure injection.Note that you can't perform requests concurrently, e.g. enter barrier from one thread and ask for node address from another thread.
INTERNAL API.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ClientFSM.AwaitDone$
static class
ClientFSM.Connected
static class
ClientFSM.Connected$
static class
ClientFSM.Connecting$
static class
ClientFSM.ConnectionFailure
static class
ClientFSM.ConnectionFailure$
static class
ClientFSM.Data
static class
ClientFSM.Data$
static class
ClientFSM.Disconnected$
static class
ClientFSM.Failed$
static interface
ClientFSM.State
-
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$, 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$
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FSM.$minus$greater$
$minus$greater()
This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.protected void
akka$actor$FSM$_setter_$Event_$eq(FSM.Event$ x$1)
protected void
akka$actor$FSM$_setter_$StateTimeout_$eq(FSM.StateTimeout$ x$1)
This case object is received in case of a state timeout.protected void
akka$actor$FSM$_setter_$StopEvent_$eq(FSM.StopEvent$ x$1)
protected void
akka$actor$LoggingFSM$_setter_$debugEvent_$eq(boolean x$1)
protected void
akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.boolean
debugEvent()
FSM.Event$
Event()
PlayerHandler
handler()
protected java.util.Set<ActorRef>
listeners()
ActorRef
self()
The 'self' field holds the ActorRef for this actor.TestConductorExt.Settings$
settings()
FSM.StateTimeout$
StateTimeout()
This case object is received in case of a state timeout.FSM.StopEvent$
StopEvent()
-
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, generation_$eq, handleEvent_$eq, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState_$eq, nextStateData, onTermination, onTransition, postStop, 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
-
Methods inherited from interface akka.actor.LoggingFSM
advance, full_$eq, getLog, logDepth, pos_$eq, processEvent, super$processEvent
-
-
-
-
Constructor Detail
-
ClientFSM
public ClientFSM(RoleName name, java.net.InetSocketAddress controllerAddr)
-
-
Method Detail
-
debugEvent
public boolean debugEvent()
- Specified by:
debugEvent
in interfaceFSM<ClientFSM.State,ClientFSM.Data>
- Specified by:
debugEvent
in interfaceLoggingFSM<ClientFSM.State,ClientFSM.Data>
-
akka$actor$LoggingFSM$_setter_$debugEvent_$eq
protected void akka$actor$LoggingFSM$_setter_$debugEvent_$eq(boolean x$1)
- Specified by:
akka$actor$LoggingFSM$_setter_$debugEvent_$eq
in interfaceLoggingFSM<ClientFSM.State,ClientFSM.Data>
-
Event
public FSM.Event$ Event()
- Specified by:
Event
in interfaceFSM<ClientFSM.State,ClientFSM.Data>
-
StopEvent
public FSM.StopEvent$ StopEvent()
- Specified by:
StopEvent
in interfaceFSM<ClientFSM.State,ClientFSM.Data>
-
$minus$greater
public FSM.$minus$greater$ $minus$greater()
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<ClientFSM.State,ClientFSM.Data>
- Returns:
- (undocumented)
-
StateTimeout
public FSM.StateTimeout$ StateTimeout()
Description copied from interface:FSM
This case object is received in case of a state timeout.- Specified by:
StateTimeout
in interfaceFSM<ClientFSM.State,ClientFSM.Data>
- Returns:
- (undocumented)
-
akka$actor$FSM$_setter_$Event_$eq
protected void akka$actor$FSM$_setter_$Event_$eq(FSM.Event$ x$1)
- Specified by:
akka$actor$FSM$_setter_$Event_$eq
in interfaceFSM<ClientFSM.State,ClientFSM.Data>
-
akka$actor$FSM$_setter_$StopEvent_$eq
protected void akka$actor$FSM$_setter_$StopEvent_$eq(FSM.StopEvent$ x$1)
- Specified by:
akka$actor$FSM$_setter_$StopEvent_$eq
in interfaceFSM<ClientFSM.State,ClientFSM.Data>
-
akka$actor$FSM$_setter_$StateTimeout_$eq
protected void akka$actor$FSM$_setter_$StateTimeout_$eq(FSM.StateTimeout$ x$1)
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<ClientFSM.State,ClientFSM.Data>
- Parameters:
x$1
- (undocumented)
-
listeners
protected java.util.Set<ActorRef> listeners()
-
akka$routing$Listeners$_setter_$listeners_$eq
protected void akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
- Specified by:
akka$routing$Listeners$_setter_$listeners_$eq
in interfaceListeners
-
context
public ActorContext context()
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()
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)
- 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)
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)
-
settings
public TestConductorExt.Settings$ settings()
-
handler
public PlayerHandler handler()
-
-