Package akka.contrib.mailbox
Class PeekMailbox
- java.lang.Object
-
- akka.contrib.mailbox.PeekMailbox
-
- All Implemented Interfaces:
MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
,UnboundedMessageQueueSemantics
,UnboundedQueueBasedMessageQueue
public class PeekMailbox extends java.lang.Object implements UnboundedQueueBasedMessageQueue
Deprecated.Use an explicit supervisor or proxy actor instead. Since 2.5.0.
-
-
Constructor Summary
Constructors Constructor Description PeekMailbox(ActorRef owner, ActorSystem system, int maxRetries)
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
ack()
Deprecated.void
cleanUp(ActorRef owner, MessageQueue deadLetters)
Deprecated.Called when the mailbox this queue belongs to is disposed of.Envelope
dequeue()
Deprecated.Try to dequeue the next message from this queue, return null failing that.int
Marker()
Deprecated.java.util.concurrent.ConcurrentLinkedQueue<Envelope>
queue()
Deprecated.int
tries()
Deprecated.void
tries_$eq(int x$1)
Deprecated.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
hasMessages, numberOfMessages
-
Methods inherited from interface akka.dispatch.UnboundedQueueBasedMessageQueue
enqueue
-
-
-
-
Constructor Detail
-
PeekMailbox
public PeekMailbox(ActorRef owner, ActorSystem system, int maxRetries)
Deprecated.
-
-
Method Detail
-
Marker
public int Marker()
Deprecated.
-
ack
public void ack()
Deprecated.
-
cleanUp
public void cleanUp(ActorRef owner, MessageQueue deadLetters)
Deprecated.Description copied from interface:MessageQueue
Called when the mailbox this queue belongs to is disposed of. Normally it is expected to transfer all remaining messages into the dead letter queue which is passed in. The owner of this MessageQueue is passed in if available (e.g. for creating DeadLetters()), “/deadletters” otherwise.- Specified by:
cleanUp
in interfaceMessageQueue
- Specified by:
cleanUp
in interfaceQueueBasedMessageQueue
- Parameters:
owner
- (undocumented)deadLetters
- (undocumented)
-
dequeue
public Envelope dequeue()
Deprecated.Description copied from interface:MessageQueue
Try to dequeue the next message from this queue, return null failing that.- Specified by:
dequeue
in interfaceMessageQueue
- Specified by:
dequeue
in interfaceUnboundedQueueBasedMessageQueue
- Returns:
- (undocumented)
-
queue
public final java.util.concurrent.ConcurrentLinkedQueue<Envelope> queue()
Deprecated.- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
tries
public int tries()
Deprecated.
-
tries_$eq
public void tries_$eq(int x$1)
Deprecated.
-
-