|
|||||||||
| 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 BoundedMessageQueueSemanticsjava.util.concurrent.BlockingDeque<Envelope> queue()
queue in interface DequeBasedMessageQueuequeue in interface QueueBasedMessageQueue
void enqueue(ActorRef receiver,
Envelope handle)
MessageQueue
enqueue in interface MessageQueuereceiver - (undocumented)handle - (undocumented)
void enqueueFirst(ActorRef receiver,
Envelope handle)
enqueueFirst in interface DequeBasedMessageQueueSemanticsEnvelope dequeue()
MessageQueue
dequeue in interface MessageQueue
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||