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 |
---|---|
protected static void |
actor_$eq(Actor a) |
static Actor |
actor() |
static ActorRef |
actorFor(ActorPath path) |
static ActorRef |
actorFor(scala.collection.Iterable<java.lang.String> path) |
static ActorRef |
actorFor(java.lang.Iterable<java.lang.String> path) |
static ActorRef |
actorFor(java.lang.String path) |
abstract static ActorRef |
actorOf(Props props) |
abstract static ActorRef |
actorOf(Props props,
java.lang.String name) |
static ActorSelection |
actorSelection(ActorPath path) |
static ActorSelection |
actorSelection(java.lang.String path) |
static FunctionRef |
addFunctionRef(scala.Function2<ActorRef,java.lang.Object,scala.runtime.BoxedUnit> f) |
protected static void |
addressTerminated(Address address) |
void |
addRoutee(Routee routee) |
void |
addRoutees(scala.collection.immutable.Iterable<Routee> routees)
Add routees to the
Router . |
protected static void |
addWatcher(ActorRef watchee,
ActorRef watcher) |
static void |
akka$actor$dungeon$Children$$_childrenRefsDoNotCallMeDirectly_$eq(ChildrenContainer x$1) |
static ChildrenContainer |
akka$actor$dungeon$Children$$_childrenRefsDoNotCallMeDirectly() |
static void |
akka$actor$dungeon$Children$$_functionRefsDoNotCallMeDirectly_$eq(scala.collection.immutable.Map<java.lang.String,FunctionRef> x$1) |
static scala.collection.immutable.Map<java.lang.String,FunctionRef> |
akka$actor$dungeon$Children$$_functionRefsDoNotCallMeDirectly() |
static void |
akka$actor$dungeon$Children$$_nextNameDoNotCallMeDirectly_$eq(long x$1) |
static long |
akka$actor$dungeon$Children$$_nextNameDoNotCallMeDirectly() |
static void |
akka$actor$dungeon$DeathWatch$$terminatedQueued_$eq(scala.collection.immutable.Set<ActorRef> x$1) |
static scala.collection.immutable.Set<ActorRef> |
akka$actor$dungeon$DeathWatch$$terminatedQueued() |
static void |
akka$actor$dungeon$DeathWatch$$watchedBy_$eq(scala.collection.immutable.Set<ActorRef> x$1) |
static scala.collection.immutable.Set<ActorRef> |
akka$actor$dungeon$DeathWatch$$watchedBy() |
static void |
akka$actor$dungeon$DeathWatch$$watching_$eq(scala.collection.immutable.Set<ActorRef> x$1) |
static scala.collection.immutable.Set<ActorRef> |
akka$actor$dungeon$DeathWatch$$watching() |
static void |
akka$actor$dungeon$Dispatch$$_mailboxDoNotCallMeDirectly_$eq(Mailbox x$1) |
static Mailbox |
akka$actor$dungeon$Dispatch$$_mailboxDoNotCallMeDirectly() |
static void |
akka$actor$dungeon$FaultHandling$$_failed_$eq(ActorRef x$1) |
static ActorRef |
akka$actor$dungeon$FaultHandling$$_failed() |
static void |
akka$actor$dungeon$ReceiveTimeout$$receiveTimeoutData_$eq(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> x$1) |
static scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> |
akka$actor$dungeon$ReceiveTimeout$$receiveTimeoutData() |
static ActorRef |
attachChild(Props props,
boolean systemService) |
static ActorRef |
attachChild(Props props,
java.lang.String name,
boolean systemService) |
static void |
autoReceiveMessage(Envelope msg) |
static void |
become(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> behavior) |
static void |
become(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> behavior,
boolean discardOld) |
static void |
become(Procedure<java.lang.Object> behavior) |
static void |
become(Procedure<java.lang.Object> behavior,
boolean discardOld) |
static boolean |
become$default$2() |
static void |
cancelReceiveTimeout() |
static void |
checkReceiveTimeout() |
abstract static scala.Option<ActorRef> |
child(java.lang.String name) |
abstract static scala.collection.immutable.Iterable<ActorRef> |
children() |
abstract static ChildrenContainer |
childrenRefs() |
protected static java.lang.Class<?> |
clazz(java.lang.Object o) |
protected static void |
clearActorCellFields(ActorCell cell) |
protected static void |
clearActorFields(Actor actorInstance,
boolean recreate) |
protected static void |
create(scala.Option<ActorInitializationException> failure) |
static void |
currentMessage_$eq(Envelope x$1) |
static Envelope |
currentMessage() |
static MessageDispatcher |
dispatcher() |
protected static void |
faultCreate() |
protected static void |
faultRecreate(java.lang.Throwable cause) |
protected static void |
faultResume(java.lang.Throwable causedByFailure) |
protected static void |
faultSuspend() |
protected static scala.collection.immutable.Iterable<ChildRestartStats> |
getAllChildStats() |
abstract static ActorRef |
getChild(java.lang.String name) |
abstract static scala.Option<ChildStats> |
getChildByName(java.lang.String name) |
protected static scala.Option<ChildRestartStats> |
getChildByRef(ActorRef ref) |
abstract static java.lang.Iterable<ActorRef> |
getChildren() |
static InternalActorRef |
getFunctionRefOrNobody(java.lang.String name,
int uid) |
static int |
getFunctionRefOrNobody$default$2() |
abstract static InternalActorRef |
getSingleChild(java.lang.String name) |
protected static InternalActorRef |
guardian() |
protected static void |
handleChildTerminated(ActorRef child) |
protected static void |
handleFailure(Failed f) |
static void |
handleInvokeFailure(scala.collection.immutable.Iterable<ActorRef> childrenNotToSuspend,
java.lang.Throwable t) |
protected static scala.PartialFunction<java.lang.Throwable,scala.runtime.BoxedUnit> |
handleNonFatalOrInterruptedException(scala.Function1<java.lang.Throwable,scala.runtime.BoxedUnit> thunk) |
protected static void |
handleSupervise(ActorRef child,
boolean async) |
abstract static boolean |
hasMessages() |
static Dispatch |
init(boolean sendSupervise,
MailboxType mailboxType) |
static scala.Option<ChildRestartStats> |
initChild(ActorRef ref) |
static Dispatch |
initWithFailure(java.lang.Throwable failure) |
static void |
invoke(Envelope messageHandle) |
static boolean |
isLocal() |
protected static boolean |
isNormal() |
abstract static boolean |
isTerminated() |
protected static boolean |
isTerminating() |
static boolean |
isWatching(ActorRef ref) |
protected static InternalActorRef |
lookupRoot() |
static Mailbox |
mailbox() |
protected static Actor |
newActor() |
abstract static int |
numberOfMessages() |
static InternalActorRef |
parent() |
protected void |
preSuperStart()
Called when
router is initialized but before super.start() to
be able to do extra initialization in subclass. |
static Props |
props() |
static ActorRefProvider |
provider() |
protected static void |
publish(Logging.LogEvent e) |
protected static java.lang.String |
randomName() |
protected static java.lang.String |
randomName(java.lang.StringBuilder sb) |
protected static void |
receivedTerminated(Terminated t) |
static void |
receiveMessage(java.lang.Object msg) |
abstract static scala.concurrent.duration.Duration |
receiveTimeout() |
protected static scala.Option<ChildrenContainer.SuspendReason> |
removeChildAndGetStateChange(ActorRef child) |
static boolean |
removeFunctionRef(FunctionRef ref) |
void |
removeRoutee(Routee routee,
boolean stopChild) |
void |
removeRoutees(scala.collection.immutable.Iterable<Routee> routees,
boolean stopChild)
Remove routees from the
Router . |
protected static void |
remWatcher(ActorRef watchee,
ActorRef watcher) |
static boolean |
reserveChild(java.lang.String name) |
abstract static void |
restart(java.lang.Throwable cause) |
abstract static void |
resume(java.lang.Throwable causedByFailure) |
protected static void |
resumeChildren(java.lang.Throwable causedByFailure,
ActorRef perp) |
Props |
routeeProps() |
Router |
router() |
RouterConfig |
routerConfig() |
static InternalActorRef |
self() |
static ActorRef |
sender() |
void |
sendMessage(Envelope envelope)
Route the message via the router to the selected destination.
|
abstract static void |
sendSystemMessage(SystemMessage msg) |
protected static void |
setActorFields(Actor actorInstance,
ActorContext context,
ActorRef self) |
protected static boolean |
setChildrenTerminationReason(ChildrenContainer.SuspendReason reason) |
abstract static void |
setReceiveTimeout(scala.concurrent.duration.Duration timeout) |
protected static void |
setTerminated() |
RoutedActorCell |
start()
Start the cell: enqueued message must not be processed before this has
been called.
|
protected static void |
stash(SystemMessage msg) |
abstract static void |
stop() |
abstract static void |
stop(ActorRef actor) |
protected static void |
stopFunctionRefs() |
abstract static void |
suspend() |
protected static void |
suspendChildren(scala.collection.immutable.Set<ActorRef> exceptFor) |
protected static scala.collection.immutable.Set<ActorRef> |
suspendChildren$default$1() |
static Mailbox |
swapMailbox(Mailbox newMailbox) |
static ActorSystemImpl |
system() |
static ActorSystemImpl |
systemImpl() |
static void |
systemInvoke(SystemMessage message) |
protected static void |
tellWatchersWeDied() |
protected static void |
terminate() |
static void |
terminatedQueuedFor(ActorRef subject) |
protected static int |
uid() |
static void |
unbecome() |
protected static boolean |
unreserveChild(java.lang.String name) |
protected static void |
unwatchWatchedActors(Actor actor) |
protected static ChildrenContainer.SuspendReason |
waitingForChildrenOrNull() |
protected static void |
watchedActorTerminated(ActorRef actor,
boolean existenceConfirmed,
boolean addressTerminated) |
protected static void |
writeObject(java.io.ObjectOutputStream o) |
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, sendMessage, setActorFields, splitNameAndUid, stash, SuspendedState, SuspendedWaitForChildrenState, system, systemImpl, systemInvoke, terminatedProps, uid, unbecome, undefinedUid, unwatch, watch
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChild, getChildren
getChild, getChildren
become, 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
cancelReceiveTimeout, checkReceiveTimeout, receiveTimeout, setReceiveTimeout
actorOf, actorOf, addFunctionRef, attachChild, attachChild, checkName, child, children, childrenRefs, functionRefs, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getFunctionRefOrNobody, getSingleChild, initChild, isNormal, isTerminating, makeChild, randomName, randomName, removeChildAndGetStateChange, removeFunctionRef, reserveChild, resumeChildren, setChildrenTerminationReason, setTerminated, stop, stopFunctionRefs, suspendChildren, swapChildrenRefs, unreserveChild, waitingForChildrenOrNull
handleException, hasMessages, init, initWithFailure, isTerminated, mailbox, numberOfMessages, restart, resume, sendSystemMessage, stop, suspend, swapMailbox
addressTerminated, addWatcher, isWatching, maintainAddressTerminatedSubscription, receivedTerminated, removeFromSet, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, watch, watchedActorTerminated, watchingContains
clearFailed, faultCreate, faultRecreate, faultResume, faultSuspend, finishCreate, finishRecreate, finishTerminate, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, isFailed, perpetrator, resumeNonRecursive, setFailed, suspendNonRecursive, terminate
public RoutedActorCell(ActorSystemImpl _system, InternalActorRef _ref, Props _routerProps, MessageDispatcher _routerDispatcher, Props routeeProps, InternalActorRef _supervisor)
public static ActorRef actorFor(java.lang.String path)
public static ActorRef actorFor(scala.collection.Iterable<java.lang.String> path)
public static ActorRef actorFor(java.lang.Iterable<java.lang.String> path)
public static ActorSelection actorSelection(java.lang.String path)
public static ActorSelection actorSelection(ActorPath path)
public abstract static void stop(ActorRef actor)
public abstract static scala.concurrent.duration.Duration receiveTimeout()
public abstract static void setReceiveTimeout(scala.concurrent.duration.Duration timeout)
public static void become(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> behavior)
public abstract static scala.collection.immutable.Iterable<ActorRef> children()
public abstract static scala.Option<ActorRef> child(java.lang.String name)
protected static final void writeObject(java.io.ObjectOutputStream o)
public abstract static java.lang.Iterable<ActorRef> getChildren()
public abstract static ActorRef getChild(java.lang.String name)
public abstract static void suspend()
public abstract static void resume(java.lang.Throwable causedByFailure)
public abstract static void restart(java.lang.Throwable cause)
public abstract static void stop()
public abstract static boolean isTerminated()
public abstract static ChildrenContainer childrenRefs()
public abstract static scala.Option<ChildStats> getChildByName(java.lang.String name)
public abstract static InternalActorRef getSingleChild(java.lang.String name)
public abstract static void sendSystemMessage(SystemMessage msg)
public abstract static boolean hasMessages()
public abstract static int numberOfMessages()
public static final void checkReceiveTimeout()
public static final void cancelReceiveTimeout()
public static ActorRef attachChild(Props props, java.lang.String name, boolean systemService)
public static InternalActorRef getFunctionRefOrNobody(java.lang.String name, int uid)
public static FunctionRef addFunctionRef(scala.Function2<ActorRef,java.lang.Object,scala.runtime.BoxedUnit> f)
public static boolean removeFunctionRef(FunctionRef ref)
protected static void stopFunctionRefs()
protected static final java.lang.String randomName(java.lang.StringBuilder sb)
protected static final java.lang.String randomName()
public static final boolean reserveChild(java.lang.String name)
protected static final boolean unreserveChild(java.lang.String name)
public static final scala.Option<ChildRestartStats> initChild(ActorRef ref)
protected static final boolean setChildrenTerminationReason(ChildrenContainer.SuspendReason reason)
protected static final void setTerminated()
protected static boolean isNormal()
protected static boolean isTerminating()
protected static ChildrenContainer.SuspendReason waitingForChildrenOrNull()
protected static void suspendChildren(scala.collection.immutable.Set<ActorRef> exceptFor)
protected static void resumeChildren(java.lang.Throwable causedByFailure, ActorRef perp)
protected static scala.Option<ChildRestartStats> getChildByRef(ActorRef ref)
protected static scala.collection.immutable.Iterable<ChildRestartStats> getAllChildStats()
protected static scala.Option<ChildrenContainer.SuspendReason> removeChildAndGetStateChange(ActorRef child)
public static int getFunctionRefOrNobody$default$2()
protected static scala.collection.immutable.Set<ActorRef> suspendChildren$default$1()
public static final Mailbox mailbox()
public static final Dispatch init(boolean sendSupervise, MailboxType mailboxType)
public static final Dispatch initWithFailure(java.lang.Throwable failure)
public static boolean isWatching(ActorRef ref)
protected static void receivedTerminated(Terminated t)
protected static void watchedActorTerminated(ActorRef actor, boolean existenceConfirmed, boolean addressTerminated)
public static void terminatedQueuedFor(ActorRef subject)
protected static void tellWatchersWeDied()
protected static void unwatchWatchedActors(Actor actor)
protected static void addressTerminated(Address address)
protected static void faultRecreate(java.lang.Throwable cause)
protected static void faultSuspend()
protected static void faultResume(java.lang.Throwable causedByFailure)
protected static void faultCreate()
protected static void terminate()
public static final void handleInvokeFailure(scala.collection.immutable.Iterable<ActorRef> childrenNotToSuspend, java.lang.Throwable t)
protected static final void handleFailure(Failed f)
protected static final void handleChildTerminated(ActorRef child)
protected static final scala.PartialFunction<java.lang.Throwable,scala.runtime.BoxedUnit> handleNonFatalOrInterruptedException(scala.Function1<java.lang.Throwable,scala.runtime.BoxedUnit> thunk)
public static ActorSystemImpl system()
public static InternalActorRef self()
public static final Props props()
public static MessageDispatcher dispatcher()
public static InternalActorRef parent()
public static final boolean isLocal()
public static final ActorSystemImpl systemImpl()
protected static final InternalActorRef guardian()
protected static final InternalActorRef lookupRoot()
public static final ActorRefProvider provider()
protected static int uid()
public static Actor actor()
protected static void actor_$eq(Actor a)
public static Envelope currentMessage()
public static void currentMessage_$eq(Envelope x$1)
protected static void stash(SystemMessage msg)
public static final void systemInvoke(SystemMessage message)
public static final void invoke(Envelope messageHandle)
public static void autoReceiveMessage(Envelope msg)
public static final void receiveMessage(java.lang.Object msg)
public static final ActorRef sender()
public static void become(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> behavior, boolean discardOld)
public static void become(Procedure<java.lang.Object> behavior)
public static void become(Procedure<java.lang.Object> behavior, boolean discardOld)
public static void unbecome()
protected static Actor newActor()
protected static void create(scala.Option<ActorInitializationException> failure)
protected static void handleSupervise(ActorRef child, boolean async)
protected static final void clearActorCellFields(ActorCell cell)
protected static final void clearActorFields(Actor actorInstance, boolean recreate)
protected static final void setActorFields(Actor actorInstance, ActorContext context, ActorRef self)
protected static final void publish(Logging.LogEvent e)
protected static final java.lang.Class<?> clazz(java.lang.Object o)
public static boolean become$default$2()
public static ActorRef akka$actor$dungeon$FaultHandling$$_failed()
public static void akka$actor$dungeon$FaultHandling$$_failed_$eq(ActorRef x$1)
public static scala.collection.immutable.Set<ActorRef> akka$actor$dungeon$DeathWatch$$watching()
public static void akka$actor$dungeon$DeathWatch$$watching_$eq(scala.collection.immutable.Set<ActorRef> x$1)
public static scala.collection.immutable.Set<ActorRef> akka$actor$dungeon$DeathWatch$$watchedBy()
public static void akka$actor$dungeon$DeathWatch$$watchedBy_$eq(scala.collection.immutable.Set<ActorRef> x$1)
public static scala.collection.immutable.Set<ActorRef> akka$actor$dungeon$DeathWatch$$terminatedQueued()
public static void akka$actor$dungeon$DeathWatch$$terminatedQueued_$eq(scala.collection.immutable.Set<ActorRef> x$1)
public static Mailbox akka$actor$dungeon$Dispatch$$_mailboxDoNotCallMeDirectly()
public static void akka$actor$dungeon$Dispatch$$_mailboxDoNotCallMeDirectly_$eq(Mailbox x$1)
public static ChildrenContainer akka$actor$dungeon$Children$$_childrenRefsDoNotCallMeDirectly()
public static void akka$actor$dungeon$Children$$_childrenRefsDoNotCallMeDirectly_$eq(ChildrenContainer x$1)
public static scala.collection.immutable.Map<java.lang.String,FunctionRef> akka$actor$dungeon$Children$$_functionRefsDoNotCallMeDirectly()
public static void akka$actor$dungeon$Children$$_functionRefsDoNotCallMeDirectly_$eq(scala.collection.immutable.Map<java.lang.String,FunctionRef> x$1)
public static long akka$actor$dungeon$Children$$_nextNameDoNotCallMeDirectly()
public static void akka$actor$dungeon$Children$$_nextNameDoNotCallMeDirectly_$eq(long x$1)
public static scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> akka$actor$dungeon$ReceiveTimeout$$receiveTimeoutData()
public static void akka$actor$dungeon$ReceiveTimeout$$receiveTimeoutData_$eq(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> x$1)
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)
sendMessage
in interface Cell
sendMessage
in interface Dispatch
sendMessage
in class ActorCell
envelope
- (undocumented)