Package akka.remote.testconductor
Class Controller
- java.lang.Object
-
- akka.remote.testconductor.Controller
-
- All Implemented Interfaces:
Actor
public class Controller extends java.lang.Object implements Actor
This controls test execution by managing barriers (delegated toBarrierCoordinator
, its child) and allowing network and other failures to be injected at the test nodes.INTERNAL API.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Controller.ClientDisconnected
static class
Controller.ClientDisconnected$
static class
Controller.ClientDisconnectedException
static class
Controller.CreateServerFSM
static class
Controller.CreateServerFSM$
static class
Controller.GetNodes$
static class
Controller.GetSockAddr$
static class
Controller.NodeInfo
static class
Controller.NodeInfo$
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description Controller(int initialParticipants, java.net.InetSocketAddress controllerPort)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Map<RoleName,scala.collection.immutable.Set<ActorRef>>
addrInterest()
void
addrInterest_$eq(scala.collection.immutable.Map<RoleName,scala.collection.immutable.Set<ActorRef>> x$1)
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.ActorRef
barrier()
org.jboss.netty.channel.Channel
connection()
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.SupervisorStrategy.Directive
failBarrier(BarrierCoordinator.Data data)
scala.collection.Iterator<java.lang.Object>
generation()
scala.collection.immutable.Map<RoleName,Controller.NodeInfo>
nodes()
void
nodes_$eq(scala.collection.immutable.Map<RoleName,Controller.NodeInfo> x$1)
void
postStop()
User overridable callback.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.ActorRef
self()
The 'self' field holds the ActorRef for this actor.TestConductorExt.Settings$
settings()
OneForOneStrategy
supervisorStrategy()
User overridable definition the strategy to use for supervising child actors.-
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, unhandled
-
-
-
-
Method Detail
-
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()
-
connection
public org.jboss.netty.channel.Channel connection()
-
supervisorStrategy
public OneForOneStrategy supervisorStrategy()
Description copied from interface:Actor
User overridable definition the strategy to use for supervising child actors.- Specified by:
supervisorStrategy
in interfaceActor
- Returns:
- (undocumented)
-
failBarrier
public SupervisorStrategy.Directive failBarrier(BarrierCoordinator.Data data)
-
barrier
public ActorRef barrier()
-
nodes
public scala.collection.immutable.Map<RoleName,Controller.NodeInfo> nodes()
-
nodes_$eq
public void nodes_$eq(scala.collection.immutable.Map<RoleName,Controller.NodeInfo> x$1)
-
addrInterest
public scala.collection.immutable.Map<RoleName,scala.collection.immutable.Set<ActorRef>> addrInterest()
-
addrInterest_$eq
public void addrInterest_$eq(scala.collection.immutable.Map<RoleName,scala.collection.immutable.Set<ActorRef>> x$1)
-
generation
public scala.collection.Iterator<java.lang.Object> generation()
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
-