ActorCell

java.lang.Object
- akka.typed.internal.ActorCell<T>

All Implemented Interfaces:: ActorContext<T>, DeathWatch<T>, SupervisionMechanics<T>, java.lang.Runnable

public class ActorCell<T>
extends java.lang.Object
implements ActorContext<T>, java.lang.Runnable, SupervisionMechanics<T>, DeathWatch<T>

INTERNAL API

Constructor Summary

Constructors
Constructor and Description
`ActorCell(ActorSystem<scala.runtime.Nothing$> system, Behavior<T> initialBehavior, scala.concurrent.ExecutionContextExecutor executionContext, int mailboxCapacity, ActorRefImpl<scala.runtime.Nothing$> parent)`

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`static int`	`activationMask()`
`static int`	`activations(int status)`
`protected static void`	`addressTerminated(Address address)`
`protected abstract static void`	`addWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee, ActorRefImpl<scala.runtime.Nothing$> watcher)`
`static void`	`akka$typed$internal$DeathWatch$$watchedBy_$eq(scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>> x$1)`
`static scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>>`	`akka$typed$internal$DeathWatch$$watchedBy()`
`static void`	`akka$typed$internal$DeathWatch$$watching_$eq(scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>> x$1)`
`static scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>>`	`akka$typed$internal$DeathWatch$$watching()`
`static void`	`akka$typed$internal$SupervisionMechanics$$_failed_$eq(java.lang.Throwable x$1)`
`static java.lang.Throwable`	`akka$typed$internal$SupervisionMechanics$$_failed()`
`protected abstract static void`	`behavior_$eq(Behavior<T> b)`
`protected Behavior<T>`	`behavior()`
`void`	`cancelReceiveTimeout()` Cancel the sending of receive timeout notifications.
`scala.Option<ActorRef<scala.runtime.Nothing$>>`	`child(java.lang.String name)` The named child Actor if it is alive.
`scala.collection.Iterable<ActorRef<scala.runtime.Nothing$>>`	`children()` The list of child Actors created by this Actor during its lifetime that are still alive, in no particular order.
`protected scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>>`	`childrenMap()`
`protected java.lang.Class<?>`	`clazz(java.lang.Object o)`
`protected ActorContext<T>`	`ctx()`
`static boolean`	`Debug()`
`static int`	`DefaultState()`
`scala.concurrent.ExecutionContextExecutor`	`executionContext()` This Actor’s execution context.
`protected static void`	`fail(java.lang.Throwable thr)`
`protected static java.lang.Throwable`	`failed()`
`protected static void`	`finishTerminate()`
`protected int`	`getStatus()`
`protected Behavior<T>`	`initialBehavior()`
`static boolean`	`isActive(int status)`
`static boolean`	`isTerminated(int status)`
`protected boolean`	`isTerminating()`
`int`	`mailboxCapacity()` Return the mailbox capacity that was configured by the parent for this actor.
`static int`	`maxActivations()`
`protected boolean`	`maySend()`
`static int`	`messageCount(int status)`
`protected void`	`next(Behavior<T> b, java.lang.Object msg)`
`ActorRefImpl<scala.runtime.Nothing$>`	`parent()`
`T`	`peekMessage()`
`protected static boolean`	`processSignal(SystemMessage message)`
`protected void`	`publish(Logging.LogEvent e)`
`protected void`	`removeChild(ActorRefImpl<scala.runtime.Nothing$> actor)`
`protected abstract static void`	`remWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee, ActorRefImpl<scala.runtime.Nothing$> watcher)`
`void`	`run()` Main entry point into the actor: the ActorCell is a Runnable that is enqueued in its Executor whenever it needs to run.
`<U> Cancellable`	`schedule(scala.concurrent.duration.FiniteDuration delay, ActorRef<U> target, U msg)` Schedule the sending of the given message to the given target Actor after the given time period has elapsed.
`ActorRefImpl<T>`	`self()` The identity of this Actor, bound to the lifecycle of this Actor instance.
`void`	`send(T msg)`
`void`	`sendSystem(SystemMessage signal)`
`protected void`	`setClosed()`
`void`	`setReceiveTimeout(scala.concurrent.duration.FiniteDuration d, T msg)` Schedule the sending of a notification in case no other message is received during the given period of time.
`void`	`setSelf(ActorRefImpl<T> ref)`
`protected void`	`setTerminating()`
`<U> ActorRef<U>`	`spawn(Behavior<U> behavior, java.lang.String name, DeploymentConfig deployment)` Create a child Actor from the given `Props` and with the given name.
`static <U> DeploymentConfig`	`spawn$default$3()`
`<U> ActorRef<U>`	`spawnAdapter(scala.Function1<U,T> f)` Create a child actor that will wrap messages such that other Actor’s protocols can be ingested by this Actor.
`<U> ActorRef<U>`	`spawnAnonymous(Behavior<U> behavior, DeploymentConfig deployment)` Create a child Actor from the given `Props` under a randomly chosen name.
`static <U> DeploymentConfig`	`spawnAnonymous$default$2()`
`static long`	`statusOffset()`
`boolean`	`stop(ActorRef<scala.runtime.Nothing$> child)` Force the child Actor under the given name to terminate after it finishes processing its current message.
`protected void`	`stopAll()`
`static int`	`SuspendedState()`
`static int`	`SuspendedWaitForChildrenState()`
`ActorSystem<scala.runtime.Nothing$>`	`system()` The `ActorSystem` to which this Actor belongs.
`static long`	`systemQueueOffset()`
`protected abstract static void`	`tellWatchersWeDied()`
`static int`	`terminatedBit()`
`scala.collection.Iterable<ActorRef<scala.runtime.Nothing$>>`	`terminating()`
`static int`	`terminatingBit()`
`protected scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>>`	`terminatingMap()`
`static int`	`terminatingShift()`
`java.lang.String`	`toString()`
`abstract static <U> ActorRef<U>`	`unwatch(ActorRef<U> other)`
`protected abstract static void`	`unwatchWatchedActors()`
`abstract static <U> ActorRef<U>`	`watch(ActorRef<U> other)`
`protected abstract static boolean`	`watchedActorTerminated(ActorRefImpl<scala.runtime.Nothing$> actor, java.lang.Throwable failure)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.typed.ActorContext
unwatch, watch

Methods inherited from interface akka.typed.internal.SupervisionMechanics
addWatcher, create, fail, failed, finishTerminate, processSignal, remWatcher, tellWatchersWeDied, terminate, unwatchWatchedActors, watchedActorTerminated

Methods inherited from interface akka.typed.internal.DeathWatch
addressTerminated, addWatcher, finishTerminate, maintainAddressTerminatedSubscription, remWatcher, subscribeAddressTerminated, tellWatchersWeDied, unsubscribeAddressTerminated, unwatch, unwatchWatchedActors, watch, watchedActorTerminated

- Constructor Detail
 - ActorCell
```
public ActorCell(ActorSystem<scala.runtime.Nothing$> system,
 Behavior<T> initialBehavior,
 scala.concurrent.ExecutionContextExecutor executionContext,
 int mailboxCapacity,
 ActorRefImpl<scala.runtime.Nothing$> parent)
```
- Method Detail
 - terminatingShift
```
public static final int terminatingShift()
```
 - activationMask
```
public static final int activationMask()
```
 - maxActivations
```
public static int maxActivations()
```
 - terminatingBit
```
public static final int terminatingBit()
```
 - terminatedBit
```
public static final int terminatedBit()
```
 - isTerminated
```
public static boolean isTerminated(int status)
```
 - isActive
```
public static boolean isActive(int status)
```
 - activations
```
public static int activations(int status)
```
 - messageCount
```
public static int messageCount(int status)
```
 - statusOffset
```
public static long statusOffset()
```
 - systemQueueOffset
```
public static long systemQueueOffset()
```
 - DefaultState
```
public static final int DefaultState()
```
 - SuspendedState
```
public static final int SuspendedState()
```
 - SuspendedWaitForChildrenState
```
public static final int SuspendedWaitForChildrenState()
```
 - Debug
```
public static final boolean Debug()
```
 - watch
```
public abstract static  ActorRef watch(ActorRef other)
```
 - unwatch
```
public abstract static  ActorRef unwatch(ActorRef other)
```
 - spawnAnonymous$default$2
```
public static  DeploymentConfig spawnAnonymous$default$2()
```
 - spawn$default$3
```
public static  DeploymentConfig spawn$default$3()
```
 - behavior_$eq
```
protected abstract static void behavior_$eq(Behavior<T> b)
```
 - addWatcher
```
protected abstract static void addWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee,
 ActorRefImpl<scala.runtime.Nothing$> watcher)
```
 - remWatcher
```
protected abstract static void remWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee,
 ActorRefImpl<scala.runtime.Nothing$> watcher)
```
 - watchedActorTerminated
```
protected abstract static boolean watchedActorTerminated(ActorRefImpl<scala.runtime.Nothing$> actor,
 java.lang.Throwable failure)
```
 - tellWatchersWeDied
```
protected abstract static void tellWatchersWeDied()
```
 - unwatchWatchedActors
```
protected abstract static void unwatchWatchedActors()
```
 - processSignal
```
protected static boolean processSignal(SystemMessage message)
```
 - akka$typed$internal$SupervisionMechanics$$_failed
```
public static java.lang.Throwable akka$typed$internal$SupervisionMechanics$$_failed()
```
 - akka$typed$internal$SupervisionMechanics$$_failed_$eq
```
public static void akka$typed$internal$SupervisionMechanics$$_failed_$eq(java.lang.Throwable x$1)
```
 - failed
```
protected static java.lang.Throwable failed()
```
 - fail
```
protected static void fail(java.lang.Throwable thr)
```
 - finishTerminate
```
protected static void finishTerminate()
```
 - akka$typed$internal$DeathWatch$$watching
```
public static scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>> akka$typed$internal$DeathWatch$$watching()
```
 - akka$typed$internal$DeathWatch$$watching_$eq
```
public static void akka$typed$internal$DeathWatch$$watching_$eq(scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>> x$1)
```
 - akka$typed$internal$DeathWatch$$watchedBy
```
public static scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>> akka$typed$internal$DeathWatch$$watchedBy()
```
 - akka$typed$internal$DeathWatch$$watchedBy_$eq
```
public static void akka$typed$internal$DeathWatch$$watchedBy_$eq(scala.collection.immutable.Set<ActorRefImpl<scala.runtime.Nothing$>> x$1)
```
 - addressTerminated
```
protected static void addressTerminated(Address address)
```
 - system
```
public ActorSystem<scala.runtime.Nothing$> system()
```
 Description copied from interface: ActorContext
 
 The ActorSystem to which this Actor belongs.
 
 Specified by:
 
 system in interface ActorContext<T>
 
 Specified by:
 
 system in interface DeathWatch<T>
 
 Specified by:
 
 system in interface SupervisionMechanics<T>
 
 Returns:
 
 (undocumented)
 - initialBehavior
```
protected Behavior<T> initialBehavior()
```
 Specified by:
 
 initialBehavior in interface SupervisionMechanics<T>
 - executionContext
```
public scala.concurrent.ExecutionContextExecutor executionContext()
```
 Description copied from interface: ActorContext
 
 This Actor’s execution context. It can be used to run asynchronous tasks like Future combinators.
 
 Specified by:
 
 executionContext in interface ActorContext<T>
 
 Returns:
 
 (undocumented)
 - mailboxCapacity
```
public int mailboxCapacity()
```
 Description copied from interface: ActorContext
 
 Return the mailbox capacity that was configured by the parent for this actor.
 
 Specified by:
 
 mailboxCapacity in interface ActorContext<T>
 
 Returns:
 
 (undocumented)
 - parent
```
public ActorRefImpl<scala.runtime.Nothing$> parent()
```
 Specified by:
 
 parent in interface DeathWatch<T>
 
 Specified by:
 
 parent in interface SupervisionMechanics<T>
 - childrenMap
```
protected scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>> childrenMap()
```
 Specified by:
 
 childrenMap in interface DeathWatch<T>
 - terminatingMap
```
protected scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>> terminatingMap()
```
 Specified by:
 
 terminatingMap in interface DeathWatch<T>
 
 Specified by:
 
 terminatingMap in interface SupervisionMechanics<T>
 - children
```
public scala.collection.Iterable<ActorRef<scala.runtime.Nothing$>> children()
```
 Description copied from interface: ActorContext
 
 The list of child Actors created by this Actor during its lifetime that are still alive, in no particular order.
 
 Specified by:
 
 children in interface ActorContext<T>
 
 Returns:
 
 (undocumented)
 - child
```
public scala.Option<ActorRef<scala.runtime.Nothing$>> child(java.lang.String name)
```
 Description copied from interface: ActorContext
 
 The named child Actor if it is alive.
 
 Specified by:
 
 child in interface ActorContext<T>
 
 Parameters:
 
 name - (undocumented)
 
 Returns:
 
 (undocumented)
 - removeChild
```
protected void removeChild(ActorRefImpl<scala.runtime.Nothing$> actor)
```
 Specified by:
 
 removeChild in interface DeathWatch<T>
 - terminating
```
public scala.collection.Iterable<ActorRef<scala.runtime.Nothing$>> terminating()
```
 - setSelf
```
public void setSelf(ActorRefImpl<T> ref)
```
 - self
```
public ActorRefImpl<T> self()
```
 Description copied from interface: ActorContext
 
 The identity of this Actor, bound to the lifecycle of this Actor instance. An Actor with the same name that lives before or after this instance will have a different ActorRef.
 
 Specified by:
 
 self in interface ActorContext<T>
 
 Specified by:
 
 self in interface DeathWatch<T>
 
 Specified by:
 
 self in interface SupervisionMechanics<T>
 
 Returns:
 
 (undocumented)
 - ctx
```
protected ActorContext<T> ctx()
```
 Specified by:
 
 ctx in interface DeathWatch<T>
 
 Specified by:
 
 ctx in interface SupervisionMechanics<T>
 - spawn
```
public  ActorRef spawn(Behavior behavior,
 java.lang.String name,
 DeploymentConfig deployment)
```
 Description copied from interface: ActorContext
 
 Create a child Actor from the given Props and with the given name.
 
 Specified by:
 
 spawn in interface ActorContext<T>
 
 Parameters:
 
 behavior - (undocumented)
 
 name - (undocumented)
 
 deployment - (undocumented)
 
 Returns:
 
 (undocumented)
 - spawnAnonymous
```
public  ActorRef spawnAnonymous(Behavior behavior,
 DeploymentConfig deployment)
```
 Description copied from interface: ActorContext
 
 Create a child Actor from the given Props under a randomly chosen name. It is good practice to name Actors wherever practical.
 
 Specified by:
 
 spawnAnonymous in interface ActorContext<T>
 
 Parameters:
 
 behavior - (undocumented)
 
 deployment - (undocumented)
 
 Returns:
 
 (undocumented)
 - stop
```
public boolean stop(ActorRef<scala.runtime.Nothing$> child)
```
 Description copied from interface: ActorContext
 
 Force the child Actor under the given name to terminate after it finishes processing its current message. Nothing happens if the ActorRef does not refer to a current child actor.
 
 Specified by:
 
 stop in interface ActorContext<T>
 
 Parameters:
 
 child - (undocumented)
 
 Returns:
 
 whether the passed-in ActorRef points to a current child Actor
 - stopAll
```
protected void stopAll()
```
 Specified by:
 
 stopAll in interface SupervisionMechanics<T>
 - schedule
```
public  Cancellable schedule(scala.concurrent.duration.FiniteDuration delay,
 ActorRef target,
 U msg)
```
 Description copied from interface: ActorContext
 
 Schedule the sending of the given message to the given target Actor after the given time period has elapsed. The scheduled action can be cancelled by invoking Cancellable cancel on the returned handle.
 
 Specified by:
 
 schedule in interface ActorContext<T>
 
 Parameters:
 
 delay - (undocumented)
 
 target - (undocumented)
 
 msg - (undocumented)
 
 Returns:
 
 (undocumented)
 - spawnAdapter
```
public  ActorRef spawnAdapter(scala.Function1<U,T> f)
```
 Description copied from interface: ActorContext
 
 Create a child actor that will wrap messages such that other Actor’s protocols can be ingested by this Actor. You are strongly advised to cache these ActorRefs or to stop them when no longer needed.
 
 Specified by:
 
 spawnAdapter in interface ActorContext<T>
 
 Parameters:
 
 f - (undocumented)
 
 Returns:
 
 (undocumented)
 - setReceiveTimeout
```
public void setReceiveTimeout(scala.concurrent.duration.FiniteDuration d,
 T msg)
```
 Description copied from interface: ActorContext
 
 Schedule the sending of a notification in case no other message is received during the given period of time. The timeout starts anew with each received message. Provide Duration.Undefined to switch off this mechanism.
 
 Specified by:
 
 setReceiveTimeout in interface ActorContext<T>
 
 Parameters:
 
 d - (undocumented)
 
 msg - (undocumented)
 - cancelReceiveTimeout
```
public void cancelReceiveTimeout()
```
 Description copied from interface: ActorContext
 
 Cancel the sending of receive timeout notifications.
 
 Specified by:
 
 cancelReceiveTimeout in interface ActorContext<T>
 - getStatus
```
protected int getStatus()
```
 - peekMessage
```
public T peekMessage()
```
 - maySend
```
protected boolean maySend()
```
 Specified by:
 
 maySend in interface DeathWatch<T>
 
 Specified by:
 
 maySend in interface SupervisionMechanics<T>
 - isTerminating
```
protected boolean isTerminating()
```
 Specified by:
 
 isTerminating in interface DeathWatch<T>
 - setTerminating
```
protected void setTerminating()
```
 Specified by:
 
 setTerminating in interface SupervisionMechanics<T>
 - setClosed
```
protected void setClosed()
```
 Specified by:
 
 setClosed in interface SupervisionMechanics<T>
 - send
```
public void send(T msg)
```
 - sendSystem
```
public void sendSystem(SystemMessage signal)
```
 - run
```
public final void run()
```
 Main entry point into the actor: the ActorCell is a Runnable that is enqueued in its Executor whenever it needs to run. The _status field is used for coordination such that it is never enqueued more than once at any given time, because that would break the Actor Model.
 The idea here is to process at most as many messages as were in queued upon entry of this method, interleaving each normal message with the processing of all system messages that may have accumulated in the meantime. If at the end of the processing messages remain in the queue then this cell is rescheduled.
 All coordination occurs via a single Int field that is only updated in wait-free manner (LOCK XADD via unsafe.getAndAddInt), where conflicts are resolved by compensating actions. For a description of the bit usage see the companion object’s source code.
 
 Specified by:
 
 run in interface java.lang.Runnable
 - behavior
```
protected Behavior<T> behavior()
```
 Specified by:
 
 behavior in interface DeathWatch<T>
 
 Specified by:
 
 behavior in interface SupervisionMechanics<T>
 - next
```
protected void next(Behavior<T> b,
 java.lang.Object msg)
```
 Specified by:
 
 next in interface DeathWatch<T>
 
 Specified by:
 
 next in interface SupervisionMechanics<T>
 - publish
```
protected final void publish(Logging.LogEvent e)
```
 Specified by:
 
 publish in interface DeathWatch<T>
 
 Specified by:
 
 publish in interface SupervisionMechanics<T>
 - clazz
```
protected final java.lang.Class<?> clazz(java.lang.Object o)
```
 Specified by:
 
 clazz in interface DeathWatch<T>
 
 Specified by:
 
 clazz in interface SupervisionMechanics<T>
 - toString
```
public java.lang.String toString()
```
 Overrides:
 
 toString in class java.lang.Object

Class ActorCell<T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface akka.typed.ActorContext

Methods inherited from interface akka.typed.internal.SupervisionMechanics

Methods inherited from interface akka.typed.internal.DeathWatch

Constructor Detail

ActorCell

Method Detail

terminatingShift

activationMask

maxActivations

terminatingBit

terminatedBit

isTerminated

isActive

activations

messageCount

statusOffset

systemQueueOffset

DefaultState

SuspendedState

SuspendedWaitForChildrenState

Debug

watch

unwatch

spawnAnonymous$default$2

spawn$default$3

behavior_$eq

addWatcher

remWatcher

watchedActorTerminated

tellWatchersWeDied

unwatchWatchedActors

processSignal

akka$typed$internal$SupervisionMechanics$$_failed

akka$typed$internal$SupervisionMechanics$$_failed_$eq

failed

fail

finishTerminate

akka$typed$internal$DeathWatch$$watching

akka$typed$internal$DeathWatch$$watching_$eq

akka$typed$internal$DeathWatch$$watchedBy

akka$typed$internal$DeathWatch$$watchedBy_$eq

addressTerminated

system

initialBehavior

executionContext

mailboxCapacity

parent

childrenMap

terminatingMap

children

child

removeChild

terminating

setSelf

self

ctx

spawn

spawnAnonymous

stop

stopAll

schedule

spawnAdapter

setReceiveTimeout

cancelReceiveTimeout

getStatus

peekMessage

maySend

isTerminating

setTerminating

setClosed

send

sendSystem

run

behavior

next

publish