|
|||||||||
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
receiver
- (undocumented)handle
- (undocumented)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 |