Package org.apache.pekko.actor
Interface Cell
-
public interface CellINTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ChildrenContainerchildrenRefs()All children of this actor, including only reserved-names.scala.Option<ChildStats>getChildByName(java.lang.String name)Get the stats for the named child, if that exists.org.apache.pekko.actor.InternalActorRefgetSingleChild(java.lang.String name)Method for looking up a single child beneath this actor.booleanhasMessages()If the actor isLocal, returns whether "user messages" are currently queued, “false” otherwise.booleanisLocal()Returns true if the actor is local, i.e.booleanisTerminated()Returns “true” if the actor is locally known to be terminated, “false” if alive or uncertain.intnumberOfMessages()If the actor isLocal, returns the number of "user messages" currently queued, which may be a costly operation, 0 otherwise.org.apache.pekko.actor.InternalActorRefparent()The supervisor of this actor.Propsprops()The props for this actor cell.voidrestart(java.lang.Throwable cause)Restart this actor (will recursively restart or stop all children).voidresume(java.lang.Throwable causedByFailure)Recursively resume this actor and all its children.ActorRefself()The “self” reference which this Cell is attached to.voidsendMessage(java.lang.Object message, ActorRef sender)Enqueue a message to be sent to the actor; may or may not actually schedule the actor to run, depending on which type of cell it is.voidsendMessage(Envelope msg)Enqueue a message to be sent to the actor; may or may not actually schedule the actor to run, depending on which type of cell it is.voidsendSystemMessage(SystemMessage msg)Enqueue a message to be sent to the actor; may or may not actually schedule the actor to run, depending on which type of cell it is.Cellstart()Start the cell: enqueued message must not be processed before this has been called.voidstop()Recursively terminate this actor and all its children.voidsuspend()Recursively suspend this actor and all its children.ActorSystemsystem()The system within which this Cell lives.org.apache.pekko.actor.ActorSystemImplsystemImpl()The system internals where this Cell lives.
-
-
-
Method Detail
-
childrenRefs
ChildrenContainer childrenRefs()
All children of this actor, including only reserved-names.
-
getChildByName
scala.Option<ChildStats> getChildByName(java.lang.String name)
Get the stats for the named child, if that exists.
-
getSingleChild
org.apache.pekko.actor.InternalActorRef getSingleChild(java.lang.String name)
Method for looking up a single child beneath this actor. It is racy if called from the outside.
-
hasMessages
boolean hasMessages()
If the actor isLocal, returns whether "user messages" are currently queued, “false” otherwise.
-
isLocal
boolean isLocal()
Returns true if the actor is local, i.e. if it is actually scheduled on a Thread in the current JVM when run.
-
isTerminated
boolean isTerminated()
Returns “true” if the actor is locally known to be terminated, “false” if alive or uncertain.
-
numberOfMessages
int numberOfMessages()
If the actor isLocal, returns the number of "user messages" currently queued, which may be a costly operation, 0 otherwise.
-
parent
org.apache.pekko.actor.InternalActorRef parent()
The supervisor of this actor.
-
props
Props props()
The props for this actor cell.
-
restart
void restart(java.lang.Throwable cause)
Restart this actor (will recursively restart or stop all children). Is only allowed to throw Fatal Throwables.
-
resume
void resume(java.lang.Throwable causedByFailure)
Recursively resume this actor and all its children. Is only allowed to throw Fatal Throwables.
-
self
ActorRef self()
The “self” reference which this Cell is attached to.
-
sendMessage
void sendMessage(Envelope msg)
Enqueue a message to be sent to the actor; may or may not actually schedule the actor to run, depending on which type of cell it is. Is only allowed to throw Fatal Throwables.
-
sendMessage
void sendMessage(java.lang.Object message, ActorRef sender)Enqueue a message to be sent to the actor; may or may not actually schedule the actor to run, depending on which type of cell it is. Is only allowed to throw Fatal Throwables.
-
sendSystemMessage
void sendSystemMessage(SystemMessage msg)
Enqueue a message to be sent to the actor; may or may not actually schedule the actor to run, depending on which type of cell it is. Is only allowed to throw Fatal Throwables.
-
start
Cell start()
Start the cell: enqueued message must not be processed before this has been called. The usual action is to attach the mailbox to a dispatcher.
-
stop
void stop()
Recursively terminate this actor and all its children. Is only allowed to throw Fatal Throwables.
-
suspend
void suspend()
Recursively suspend this actor and all its children. Is only allowed to throw Fatal Throwables.
-
system
ActorSystem system()
The system within which this Cell lives.
-
systemImpl
org.apache.pekko.actor.ActorSystemImpl systemImpl()
The system internals where this Cell lives.
-
-