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 Envelopedequeue()Try to dequeue the next message from this queue, return null failing that.voidenqueue(ActorRef receiver, Envelope handle)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:MessageQueueTry to dequeue the next message from this queue, return null failing that.- Specified by:
dequeuein interfaceMessageQueue- Returns:
- (undocumented)
-
enqueue
void enqueue(ActorRef receiver, Envelope handle)
- Specified by:
enqueuein interfaceMessageQueue
-
queue
java.util.concurrent.BlockingQueue<Envelope> queue()
- Specified by:
queuein interfaceQueueBasedMessageQueue
-
-