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.
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