public class PeekMailbox
extends java.lang.Object
implements akka.dispatch.UnboundedQueueBasedMessageQueue
Constructor and Description |
---|
PeekMailbox(akka.actor.ActorRef owner,
akka.actor.ActorSystem system,
int maxRetries) |
Modifier and Type | Method and Description |
---|---|
void |
ack() |
void |
cleanUp(akka.actor.ActorRef owner,
akka.dispatch.MessageQueue deadLetters) |
akka.dispatch.Envelope |
dequeue() |
int |
Marker() |
java.util.concurrent.ConcurrentLinkedQueue<akka.dispatch.Envelope> |
queue() |
int |
tries() |
public PeekMailbox(akka.actor.ActorRef owner, akka.actor.ActorSystem system, int maxRetries)
public final java.util.concurrent.ConcurrentLinkedQueue<akka.dispatch.Envelope> queue()
queue
in interface akka.dispatch.QueueBasedMessageQueue
public int tries()
public int Marker()
public akka.dispatch.Envelope dequeue()
dequeue
in interface akka.dispatch.MessageQueue
dequeue
in interface akka.dispatch.UnboundedQueueBasedMessageQueue
public void ack()
public void cleanUp(akka.actor.ActorRef owner, akka.dispatch.MessageQueue deadLetters)
cleanUp
in interface akka.dispatch.MessageQueue
cleanUp
in interface akka.dispatch.QueueBasedMessageQueue