public class RoutedActorCell extends ActorCell
Modifier and Type | Class and Description |
---|---|
static class |
RoutedActorCell.RouterActorCreator |
Constructor and Description |
---|
RoutedActorCell(ActorSystemImpl _system,
InternalActorRef _ref,
Props _routerProps,
MessageDispatcher _routerDispatcher,
Props routeeProps,
InternalActorRef _supervisor) |
Modifier and Type | Method and Description |
---|---|
void |
addRoutee(Routee routee) |
void |
addRoutees(scala.collection.immutable.Iterable<Routee> routees)
Add routees to the
Router . |
protected void |
preSuperStart()
Called when
router is initialized but before super.start() to
be able to do extra initialization in subclass. |
void |
removeRoutee(Routee routee,
boolean stopChild) |
void |
removeRoutees(scala.collection.immutable.Iterable<Routee> routees,
boolean stopChild)
Remove routees from the
Router . |
Props |
routeeProps() |
Router |
router() |
RouterConfig |
routerConfig() |
void |
sendMessage(Envelope envelope)
Route the message via the router to the selected destination.
|
RoutedActorCell |
start()
Start the cell: enqueued message must not be processed before this has
been called.
|
actor, autoReceiveMessage, become, become, become, clazz, clearActorCellFields, clearActorFields, contextStack, create, currentMessage, DefaultState, dispatcher, emptyActorRefSet, emptyBehaviorStack, emptyCancellable, guardian, handleSupervise, invoke, isLocal, lookupRoot, newActor, newUid, parent, props, provider, publish, receiveMessage, self, sender, setActorFields, splitNameAndUid, stash, SuspendedState, SuspendedWaitForChildrenState, system, systemImpl, systemInvoke, terminatedProps, uid, unbecome, undefinedUid
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChild, getChildren
child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, writeObject
actorFor, actorFor, actorFor, actorFor, actorOf, actorOf, actorSelection, actorSelection, stop
childrenRefs, getChildByName, getSingleChild, hasMessages, isTerminated, numberOfMessages, restart, resume, sendMessage, sendSystemMessage, stop, suspend
public RoutedActorCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props routeeProps, InternalActorRef _supervisor)
public Props routeeProps()
public RouterConfig routerConfig()
public Router router()
public void addRoutee(Routee routee)
public void addRoutees(scala.collection.immutable.Iterable<Routee> routees)
Router
. Messages in flight may still be routed to
the old Router
instance containing the old routees.routees
- (undocumented)public void removeRoutee(Routee routee, boolean stopChild)
public void removeRoutees(scala.collection.immutable.Iterable<Routee> routees, boolean stopChild)
Router
. Messages in flight may still be routed to
the old Router
instance containing the old routees.routees
- (undocumented)stopChild
- (undocumented)public RoutedActorCell start()
Cell
protected void preSuperStart()
router
is initialized but before super.start()
to
be able to do extra initialization in subclass.public void sendMessage(Envelope envelope)
envelope
- (undocumented)