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)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:MessageQueueTry to dequeue the next message from this queue, return null failing that.- Specified by:
dequeuein interfaceMessageQueue
-
enqueue
void enqueue(ActorRef receiver, Envelope handle)
Description copied from interface:MessageQueueTry to enqueue the message to this queue, or throw an exception.- Specified by:
enqueuein interfaceMessageQueue
-
queue
java.util.concurrent.BlockingQueue<Envelope> queue()
- Specified by:
queuein interfaceQueueBasedMessageQueue
-
-