public class CallingThreadMailbox
extends akka.dispatch.Mailbox
implements akka.dispatch.DefaultSystemMessageQueue
Constructor and Description |
---|
CallingThreadMailbox(akka.actor.Cell _receiver,
akka.dispatch.MailboxType mailboxType) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
java.util.concurrent.locks.ReentrantLock |
ctdLock() |
akka.dispatch.Envelope |
dequeue() |
void |
enqueue(akka.actor.ActorRef receiver,
akka.dispatch.Envelope msg) |
boolean |
hasMessages() |
akka.dispatch.MailboxType |
mailboxType() |
akka.dispatch.MessageQueue |
messageQueue()
This is only a marker to be put in the messageQueue’s stead to make error
messages pertaining to violated mailbox type requirements less cryptic.
|
int |
numberOfMessages() |
akka.dispatch.MessageQueue |
queue() |
akka.actor.ActorRef |
self() |
akka.util.Switch |
suspendSwitch() |
akka.actor.ActorSystem |
system() |
_statusDoNotCallMeDirectly_$eq, _statusDoNotCallMeDirectly, _systemQueueDoNotCallMeDirectly_$eq, _systemQueueDoNotCallMeDirectly, actor_$eq, actor, becomeClosed, canBeScheduledForExecution, Closed, currentStatus, debug, dispatcher, exec, getRawResult, isClosed, isScheduled, isSuspended, Open, processAllSystemMessages, resume, run, Scheduled, setActor, setAsIdle, setAsScheduled, setRawResult, setStatus, shouldNotProcessMask, shouldProcessMessage, shouldScheduleMask, suspend, suspendCount, suspendMask, suspendUnit, systemQueueGet, systemQueuePut, updateStatus
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public CallingThreadMailbox(akka.actor.Cell _receiver, akka.dispatch.MailboxType mailboxType)
public akka.dispatch.MailboxType mailboxType()
public akka.actor.ActorSystem system()
public akka.actor.ActorRef self()
public akka.dispatch.MessageQueue messageQueue()
messageQueue
in class akka.dispatch.Mailbox
public void enqueue(akka.actor.ActorRef receiver, akka.dispatch.Envelope msg)
enqueue
in class akka.dispatch.Mailbox
public akka.dispatch.Envelope dequeue()
dequeue
in class akka.dispatch.Mailbox
public boolean hasMessages()
hasMessages
in class akka.dispatch.Mailbox
public int numberOfMessages()
numberOfMessages
in class akka.dispatch.Mailbox
public akka.dispatch.MessageQueue queue()
public java.util.concurrent.locks.ReentrantLock ctdLock()
public akka.util.Switch suspendSwitch()
public void cleanUp()
cleanUp
in class akka.dispatch.Mailbox