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()
 
 - 
 
 -