akka.dispatch
Interface UnboundedDequeBasedMessageQueueSemantics

All Superinterfaces:

DequeBasedMessageQueue, MessageQueue, QueueBasedMessageQueue

public interface UnboundedDequeBasedMessageQueueSemantics
extends DequeBasedMessageQueue

UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, 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.
void	enqueueFirst(ActorRef receiver, Envelope handle)

Methods inherited from interface akka.dispatch.DequeBasedMessageQueue

queue

Methods inherited from interface akka.dispatch.QueueBasedMessageQueue

cleanUp, hasMessages, numberOfMessages

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

enqueueFirst

void enqueueFirst(ActorRef receiver,
                  Envelope handle)

Specified by:

enqueueFirst in interface DequeBasedMessageQueue

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