|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectakka.contrib.mailbox.PeekMailbox
public class PeekMailbox
Constructor Summary | |
---|---|
PeekMailbox(ActorRef owner,
ActorSystem system,
int maxRetries)
|
Method Summary | |
---|---|
void |
ack()
|
void |
cleanUp(ActorRef owner,
MessageQueue deadLetters)
Called when the mailbox this queue belongs to is disposed of. |
Envelope |
dequeue()
Try to dequeue the next message from this queue, return null failing that. |
int |
Marker()
|
java.util.concurrent.ConcurrentLinkedQueue<Envelope> |
queue()
|
int |
tries()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.dispatch.UnboundedQueueBasedMessageQueue |
---|
enqueue |
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue |
---|
hasMessages, numberOfMessages |
Constructor Detail |
---|
public PeekMailbox(ActorRef owner, ActorSystem system, int maxRetries)
Method Detail |
---|
public final java.util.concurrent.ConcurrentLinkedQueue<Envelope> queue()
queue
in interface QueueBasedMessageQueue
public int tries()
public int Marker()
public Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue
dequeue
in interface UnboundedQueueBasedMessageQueue
public void ack()
public void cleanUp(ActorRef owner, MessageQueue deadLetters)
MessageQueue
cleanUp
in interface MessageQueue
cleanUp
in interface QueueBasedMessageQueue
owner
- (undocumented)deadLetters
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |