akka.dispatch
Interface UnboundedMessageQueueSemantics

All Superinterfaces:
MessageQueue, QueueBasedMessageQueue
All Known Implementing Classes:
PeekMailbox

public interface UnboundedMessageQueueSemantics
extends QueueBasedMessageQueue

UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.e. a non-blocking enqueue and dequeue.


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.
 
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages, queue
 

Method Detail

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

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