|
|||||||||
| 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 MessageQueue
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 | ||||||||