|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.dispatch.Mailbox akka.testkit.CallingThreadMailbox
public class CallingThreadMailbox
Constructor Summary | |
---|---|
CallingThreadMailbox(Cell _receiver,
MailboxType mailboxType)
|
Method Summary | |
---|---|
void |
cleanUp()
Overridable callback to clean up the mailbox, called when an actor is unregistered. |
java.util.concurrent.locks.ReentrantLock |
ctdLock()
|
Envelope |
dequeue()
Try to dequeue the next message from this queue, return null failing that. |
void |
enqueue(ActorRef receiver,
Envelope msg)
Try to enqueue the message to this queue, or throw an exception. |
boolean |
hasMessages()
Indicates whether this queue is non-empty. |
MailboxType |
mailboxType()
|
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()
Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently. |
MessageQueue |
queue()
|
ActorRef |
self()
|
Switch |
suspendSwitch()
|
ActorSystem |
system()
|
Methods inherited from class akka.dispatch.Mailbox |
---|
_statusDoNotCallMeDirectly, _systemQueueDoNotCallMeDirectly, actor, becomeClosed, canBeScheduledForExecution, Closed, currentStatus, debug, dispatcher, isClosed, isScheduled, isSuspended, Open, processAllSystemMessages, resume, run, Scheduled, setActor, setAsIdle, setAsScheduled, setStatus, shouldNotProcessMask, shouldProcessMessage, shouldScheduleMask, suspend, suspendCount, suspendMask, suspendUnit, systemQueueGet, systemQueuePut, updateStatus |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.dispatch.DefaultSystemMessageQueue |
---|
hasSystemMessages, systemDrain, systemEnqueue |
Methods inherited from interface akka.dispatch.SystemMessageQueue |
---|
hasSystemMessages, systemDrain, systemEnqueue |
Constructor Detail |
---|
public CallingThreadMailbox(Cell _receiver, MailboxType mailboxType)
Method Detail |
---|
public MailboxType mailboxType()
public ActorSystem system()
public ActorRef self()
public MessageQueue messageQueue()
messageQueue
in class Mailbox
public void enqueue(ActorRef receiver, Envelope msg)
Mailbox
enqueue
in class Mailbox
receiver
- (undocumented)msg
- (undocumented)public Envelope dequeue()
Mailbox
dequeue
in class Mailbox
public boolean hasMessages()
Mailbox
hasMessages
in class Mailbox
public int numberOfMessages()
Mailbox
hasMessages
instead.
numberOfMessages
in class Mailbox
public MessageQueue queue()
public java.util.concurrent.locks.ReentrantLock ctdLock()
public Switch suspendSwitch()
public void cleanUp()
Mailbox
cleanUp
in class Mailbox
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |