|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectakka.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 ActorContextsystem in interface Cellpublic InternalActorRef self()
Cell
self in interface ActorContextself in interface Cellpublic final Props props()
ActorContext
props in interface ActorContextprops in interface Cellpublic MessageDispatcher dispatcher()
ActorContext
dispatcher in interface ActorContextdispatcher in interface ActorRefFactorypublic InternalActorRef parent()
ActorContext
parent in interface ActorContextparent in interface Cellpublic final boolean isLocal()
Cell
isLocal in interface Cellpublic final ActorSystemImpl systemImpl()
ActorRefFactory
systemImpl in interface ActorRefFactorysystemImpl in interface Cellprotected final InternalActorRef guardian()
ActorRefFactoryINTERNAL API
guardian in interface ActorRefFactoryprotected final InternalActorRef lookupRoot()
ActorRefFactory
lookupRoot in interface ActorRefFactorypublic final ActorRefProvider provider()
ActorRefFactory
provider in interface ActorRefFactoryprotected 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 ActorContextbehavior - (undocumented)discardOld - (undocumented)public void become(Procedure<java.lang.Object> behavior)
UntypedActorContext
become in interface UntypedActorContextbehavior - (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 UntypedActorContextbehavior - (undocumented)discardOld - (undocumented)public void unbecome()
ActorContext
unbecome in interface ActorContextprotected 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 | ||||||||