akka.dispatch
Interface BoundedDequeBasedMessageQueue

All Superinterfaces:
BoundedDequeBasedMessageQueueSemantics, BoundedMessageQueueSemantics, DequeBasedMessageQueue, DequeBasedMessageQueueSemantics, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue
All Known Implementing Classes:
BoundedDequeBasedMailbox.MessageQueue

public interface BoundedDequeBasedMessageQueue
extends DequeBasedMessageQueue, BoundedDequeBasedMessageQueueSemantics

BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e. blocking enqueue with timeout.


Method Summary
 Envelope dequeue()
          Try to dequeue the next message from this queue, return null failing that.
 void enqueue(ActorRef receiver, Envelope handle)
          Try to enqueue the message to this queue, or throw an exception.
 void enqueueFirst(ActorRef receiver, Envelope handle)
           
 scala.concurrent.duration.Duration pushTimeOut()
           
 java.util.concurrent.BlockingDeque<Envelope> queue()
           
 
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
 

Method Detail

pushTimeOut

scala.concurrent.duration.Duration pushTimeOut()
Specified by:
pushTimeOut in interface BoundedMessageQueueSemantics

queue

java.util.concurrent.BlockingDeque<Envelope> queue()
Specified by:
queue in interface DequeBasedMessageQueue
Specified by:
queue in interface QueueBasedMessageQueue

enqueue

void enqueue(ActorRef receiver,
             Envelope handle)
Description copied from interface: MessageQueue
Try to enqueue the message to this queue, or throw an exception.

Specified by:
enqueue in interface MessageQueue
Parameters:
receiver - (undocumented)
handle - (undocumented)

enqueueFirst

void enqueueFirst(ActorRef receiver,
                  Envelope handle)
Specified by:
enqueueFirst in interface DequeBasedMessageQueueSemantics

dequeue

Envelope dequeue()
Description copied from interface: MessageQueue
Try to dequeue the next message from this queue, return null failing that.

Specified by:
dequeue in interface MessageQueue
Returns:
(undocumented)