Package akka.dispatch
Interface BoundedQueueBasedMessageQueue
-
- All Superinterfaces:
BoundedMessageQueueSemantics
,MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
- All Known Implementing Classes:
BoundedMailbox.MessageQueue
,BoundedPriorityMailbox.MessageQueue
,BoundedStablePriorityMailbox.MessageQueue
public interface BoundedQueueBasedMessageQueue extends QueueBasedMessageQueue, BoundedMessageQueueSemantics
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description 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.java.util.concurrent.BlockingQueue<Envelope>
queue()
-
Methods inherited from interface akka.dispatch.BoundedMessageQueueSemantics
pushTimeOut
-
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
-
-
-
-
Method Detail
-
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 interfaceMessageQueue
-
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 interfaceMessageQueue
-
queue
java.util.concurrent.BlockingQueue<Envelope> queue()
- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
-