Package akka.testkit
Class CallingThreadMailbox
- java.lang.Object
-
- akka.dispatch.Mailbox
-
- akka.testkit.CallingThreadMailbox
-
- All Implemented Interfaces:
DefaultSystemMessageQueue
public class CallingThreadMailbox extends akka.dispatch.Mailbox implements DefaultSystemMessageQueue
-
-
Constructor Summary
Constructors Constructor Description CallingThreadMailbox(Cell _receiver, MailboxType mailboxType)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanUp()
java.util.concurrent.locks.ReentrantLock
ctdLock()
Envelope
dequeue()
void
enqueue(ActorRef receiver, Envelope msg)
boolean
hasMessages()
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()
MessageQueue
queue()
ActorRef
self()
Switch
suspendSwitch()
ActorSystem
system()
-
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
-
-
-
-
Constructor Detail
-
CallingThreadMailbox
public CallingThreadMailbox(Cell _receiver, MailboxType mailboxType)
-
-
Method Detail
-
cleanUp
public void cleanUp()
-
ctdLock
public java.util.concurrent.locks.ReentrantLock ctdLock()
-
dequeue
public Envelope dequeue()
-
hasMessages
public boolean hasMessages()
-
mailboxType
public MailboxType mailboxType()
-
messageQueue
public 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.
-
numberOfMessages
public int numberOfMessages()
-
queue
public MessageQueue queue()
-
self
public ActorRef self()
-
suspendSwitch
public Switch suspendSwitch()
-
system
public ActorSystem system()
-
-