Package org.apache.pekko.testkit

Class CallingThreadMailbox

java.lang.Object

org.apache.pekko.dispatch.Mailbox

org.apache.pekko.testkit.CallingThreadMailbox

All Implemented Interfaces:

DefaultSystemMessageQueue

public class CallingThreadMailbox
extends org.apache.pekko.dispatch.Mailbox
implements DefaultSystemMessageQueue

Constructor Summary

Constructors

Constructor	Description
CallingThreadMailbox(Cell _receiver, MailboxType mailboxType)

Method Summary

Modifier and Type	Method	Description
void	cleanUp()
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 org.apache.pekko.dispatch.DefaultSystemMessageQueue

hasSystemMessages, systemDrain, systemEnqueue

Constructor Details

CallingThreadMailbox

public CallingThreadMailbox(Cell _receiver,
 MailboxType mailboxType)

Method Details

cleanUp

public void cleanUp()

ctdLock

public ReentrantLock ctdLock()

dequeue

public Envelope dequeue()

enqueue

public void enqueue(ActorRef receiver,
 Envelope msg)

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