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 voidcleanUp()java.util.concurrent.locks.ReentrantLockctdLock()Envelopedequeue()voidenqueue(ActorRef receiver, Envelope msg)booleanhasMessages()MailboxTypemailboxType()MessageQueuemessageQueue()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.intnumberOfMessages()MessageQueuequeue()ActorRefself()SwitchsuspendSwitch()ActorSystemsystem()-
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()
-
-