|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface BoundedDequeBasedMessageQueue
BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e. blocking enqueue with timeout.
Method Summary | |
---|---|
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. |
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 |
---|
scala.concurrent.duration.Duration pushTimeOut()
pushTimeOut
in interface BoundedMessageQueueSemantics
java.util.concurrent.BlockingDeque<Envelope> queue()
queue
in interface DequeBasedMessageQueue
queue
in interface QueueBasedMessageQueue
void enqueue(ActorRef receiver, Envelope handle)
MessageQueue
enqueue
in interface MessageQueue
void enqueueFirst(ActorRef receiver, Envelope handle)
enqueueFirst
in interface DequeBasedMessageQueueSemantics
Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |