Package akka.dispatch
Interface BoundedDequeBasedMessageQueue
-
- All Superinterfaces:
BoundedDequeBasedMessageQueueSemantics
,BoundedMessageQueueSemantics
,DequeBasedMessageQueue
,DequeBasedMessageQueueSemantics
,MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
- All Known Implementing Classes:
BoundedDequeBasedMailbox.MessageQueue
public interface BoundedDequeBasedMessageQueue extends DequeBasedMessageQueue, BoundedDequeBasedMessageQueueSemantics
BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e. blocking enqueue with timeout.
-
-
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)
void
enqueueFirst(ActorRef receiver, Envelope handle)
scala.concurrent.duration.Duration
pushTimeOut()
java.util.concurrent.BlockingDeque<Envelope>
queue()
-
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
- Returns:
- (undocumented)
-
enqueue
void enqueue(ActorRef receiver, Envelope handle)
- Specified by:
enqueue
in interfaceMessageQueue
-
enqueueFirst
void enqueueFirst(ActorRef receiver, Envelope handle)
- Specified by:
enqueueFirst
in interfaceDequeBasedMessageQueueSemantics
-
pushTimeOut
scala.concurrent.duration.Duration pushTimeOut()
- Specified by:
pushTimeOut
in interfaceBoundedMessageQueueSemantics
-
queue
java.util.concurrent.BlockingDeque<Envelope> queue()
- Specified by:
queue
in interfaceDequeBasedMessageQueue
- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
-