|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.ActorCell
public class ActorCell
Everything in here is completely Akka PRIVATE. You will not find any supported APIs in this place. This is not the API you were looking for! (waves hand)
Constructor Summary | |
---|---|
ActorCell(ActorSystemImpl system,
InternalActorRef self,
Props props,
MessageDispatcher dispatcher,
InternalActorRef parent)
|
Method Summary | |
---|---|
Actor |
actor()
|
void |
autoReceiveMessage(Envelope msg)
|
void |
become(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> behavior,
boolean discardOld)
Changes the Actor's behavior to become the new 'Receive' (PartialFunction[Any, Unit]) handler. |
void |
become(Procedure<java.lang.Object> behavior)
Changes the Actor's behavior to become the new 'Procedure' handler. |
void |
become(Procedure<java.lang.Object> behavior,
boolean discardOld)
Changes the Actor's behavior to become the new 'Procedure' handler. |
protected java.lang.Class<?> |
clazz(java.lang.Object o)
|
protected void |
clearActorCellFields(ActorCell cell)
|
protected void |
clearActorFields(Actor actorInstance,
boolean recreate)
|
static java.lang.ThreadLocal<scala.collection.immutable.List<ActorContext>> |
contextStack()
|
protected void |
create(scala.Option<ActorInitializationException> failure)
|
Envelope |
currentMessage()
|
static int |
DefaultState()
|
MessageDispatcher |
dispatcher()
Returns the dispatcher (MessageDispatcher) that is used for this Actor. |
static scala.collection.immutable.Set<ActorRef> |
emptyActorRefSet()
|
static scala.collection.immutable.List<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> |
emptyBehaviorStack()
|
static Cancellable |
emptyCancellable()
|
protected InternalActorRef |
guardian()
Father of all children created by this interface. |
protected void |
handleSupervise(ActorRef child,
boolean async)
|
void |
invoke(Envelope messageHandle)
|
boolean |
isLocal()
Returns true if the actor is local, i.e. |
protected InternalActorRef |
lookupRoot()
INTERNAL API |
protected Actor |
newActor()
|
static int |
newUid()
|
InternalActorRef |
parent()
Returns the supervising parent ActorRef. |
Props |
props()
Retrieve the Props which were used to create this actor. |
ActorRefProvider |
provider()
INTERNAL API |
protected void |
publish(Logging.LogEvent e)
|
void |
receiveMessage(java.lang.Object msg)
|
InternalActorRef |
self()
The “self” reference which this Cell is attached to. |
ActorRef |
sender()
Returns the sender 'ActorRef' of the current message. |
protected void |
setActorFields(Actor actorInstance,
ActorContext context,
ActorRef self)
|
static scala.Tuple2<java.lang.String,java.lang.Object> |
splitNameAndUid(java.lang.String name)
|
protected void |
stash(SystemMessage msg)
|
static int |
SuspendedState()
|
static int |
SuspendedWaitForChildrenState()
|
ActorSystemImpl |
system()
The system that the actor belongs to. |
ActorSystemImpl |
systemImpl()
INTERNAL API |
void |
systemInvoke(SystemMessage message)
|
static Props |
terminatedProps()
|
protected int |
uid()
|
void |
unbecome()
Reverts the Actor behavior to the previous one on the behavior stack. |
static int |
undefinedUid()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.actor.UntypedActorContext |
---|
getChild, getChildren |
Methods inherited from interface akka.actor.AbstractActorContext |
---|
getChild, getChildren |
Methods inherited from interface akka.actor.ActorContext |
---|
become, child, children, receiveTimeout, setReceiveTimeout, unwatch, watch, writeObject |
Methods inherited from interface akka.actor.ActorRefFactory |
---|
actorFor, actorFor, actorFor, actorFor, actorOf, actorOf, actorSelection, actorSelection, stop |
Methods inherited from interface akka.actor.Cell |
---|
childrenRefs, getChildByName, getSingleChild, hasMessages, isTerminated, numberOfMessages, restart, resume, sendMessage, sendMessage, sendSystemMessage, start, stop, suspend |
Methods inherited from interface akka.actor.dungeon.ReceiveTimeout |
---|
cancelReceiveTimeout, checkReceiveTimeout, receiveTimeout, receiveTimeoutData, setReceiveTimeout |
Methods inherited from interface akka.actor.dungeon.Children |
---|
_childrenRefsDoNotCallMeDirectly, _nextNameDoNotCallMeDirectly, actorOf, actorOf, attachChild, attachChild, checkName, child, children, childrenRefs, getAllChildStats, getChild, getChildByName, getChildByRef, getChildren, getSingleChild, initChild, isNormal, isTerminating, makeChild, randomName, removeChildAndGetStateChange, reserveChild, resumeChildren, setChildrenTerminationReason, setTerminated, stop, suspendChildren, swapChildrenRefs, unreserveChild, waitingForChildrenOrNull |
Methods inherited from interface akka.actor.dungeon.Dispatch |
---|
_mailboxDoNotCallMeDirectly, handleException, hasMessages, init, isTerminated, mailbox, numberOfMessages, restart, resume, sendMessage, sendSystemMessage, start, stop, suspend, swapMailbox |
Methods inherited from interface akka.actor.dungeon.DeathWatch |
---|
addressTerminated, addWatcher, maintainAddressTerminatedSubscription, receivedTerminated, removeFromSet, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, terminatedQueued, terminatedQueuedFor, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, watch, watchedActorTerminated, watchedBy, watching, watchingContains |
Methods inherited from interface akka.actor.dungeon.FaultHandling |
---|
_failed, clearFailed, faultCreate, faultRecreate, faultResume, faultSuspend, finishCreate, finishRecreate, finishTerminate, handleChildTerminated, handleFailure, handleInvokeFailure, handleNonFatalOrInterruptedException, isFailed, perpetrator, resumeNonRecursive, setFailed, suspendNonRecursive, terminate |
Constructor Detail |
---|
public ActorCell(ActorSystemImpl system, InternalActorRef self, Props props, MessageDispatcher dispatcher, InternalActorRef parent)
Method Detail |
---|
public static java.lang.ThreadLocal<scala.collection.immutable.List<ActorContext>> contextStack()
public static final Cancellable emptyCancellable()
public static final scala.collection.immutable.List<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> emptyBehaviorStack()
public static final scala.collection.immutable.Set<ActorRef> emptyActorRefSet()
public static final Props terminatedProps()
public static final int undefinedUid()
public static final int newUid()
public static final scala.Tuple2<java.lang.String,java.lang.Object> splitNameAndUid(java.lang.String name)
public static final int DefaultState()
public static final int SuspendedState()
public static final int SuspendedWaitForChildrenState()
public ActorSystemImpl system()
ActorContext
system
in interface ActorContext
system
in interface Cell
public InternalActorRef self()
Cell
self
in interface ActorContext
self
in interface Cell
public final Props props()
ActorContext
props
in interface ActorContext
props
in interface Cell
public MessageDispatcher dispatcher()
ActorContext
dispatcher
in interface ActorContext
dispatcher
in interface ActorRefFactory
public InternalActorRef parent()
ActorContext
parent
in interface ActorContext
parent
in interface Cell
public final boolean isLocal()
Cell
isLocal
in interface Cell
public final ActorSystemImpl systemImpl()
ActorRefFactory
systemImpl
in interface ActorRefFactory
systemImpl
in interface Cell
protected final InternalActorRef guardian()
ActorRefFactory
INTERNAL API
guardian
in interface ActorRefFactory
protected final InternalActorRef lookupRoot()
ActorRefFactory
lookupRoot
in interface ActorRefFactory
public final ActorRefProvider provider()
ActorRefFactory
provider
in interface ActorRefFactory
protected int uid()
public Actor actor()
public Envelope currentMessage()
protected void stash(SystemMessage msg)
public final void systemInvoke(SystemMessage message)
public final void invoke(Envelope messageHandle)
public void autoReceiveMessage(Envelope msg)
public final void receiveMessage(java.lang.Object msg)
public final ActorRef sender()
ActorContext
sender
in interface ActorContext
public void become(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> behavior, boolean discardOld)
ActorContext
- if discardOld = true
it will replace the top element (i.e. the current behavior)
- if discardOld = false
it will keep the current behavior and push the given one atop
The default of replacing the current behavior on the stack has been chosen to avoid memory
leaks in case client code is written without consulting this documentation first (i.e.
always pushing new behaviors and never issuing an unbecome()
)
become
in interface ActorContext
behavior
- (undocumented)discardOld
- (undocumented)public void become(Procedure<java.lang.Object> behavior)
UntypedActorContext
become
in interface UntypedActorContext
behavior
- (undocumented)public void become(Procedure<java.lang.Object> behavior, boolean discardOld)
UntypedActorContext
- if discardOld = true
it will replace the top element (i.e. the current behavior)
- if discardOld = false
it will keep the current behavior and push the given one atop
The default of replacing the current behavior on the stack has been chosen to avoid memory
leaks in case client code is written without consulting this documentation first (i.e.
always pushing new behaviors and never issuing an unbecome()
)
become
in interface UntypedActorContext
behavior
- (undocumented)discardOld
- (undocumented)public void unbecome()
ActorContext
unbecome
in interface ActorContext
protected Actor newActor()
protected void create(scala.Option<ActorInitializationException> failure)
protected void handleSupervise(ActorRef child, boolean async)
protected final void clearActorCellFields(ActorCell cell)
protected final void clearActorFields(Actor actorInstance, boolean recreate)
protected final void setActorFields(Actor actorInstance, ActorContext context, ActorRef self)
protected final void publish(Logging.LogEvent e)
protected final java.lang.Class<?> clazz(java.lang.Object o)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |