|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface BoundedDequeBasedMessageQueueSemantics
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()
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 DequeBasedMessageQueue
Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |