Package akka.dispatch

Interface ControlAwareMessageQueueSemantics

All Superinterfaces:

MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue

All Known Subinterfaces:

BoundedControlAwareMessageQueueSemantics, UnboundedControlAwareMessageQueueSemantics

All Known Implementing Classes:

BoundedControlAwareMailbox.MessageQueue, UnboundedControlAwareMailbox.MessageQueue

public interface ControlAwareMessageQueueSemantics
extends QueueBasedMessageQueue

ControlAwareMessageQueue handles messages that extend ControlMessage with priority.

Method Summary

Modifier and Type	Method	Description
java.util.Queue<Envelope>	controlQueue()
Envelope	dequeue()	Try to dequeue the next message from this queue, return null failing that.
void	enqueue(ActorRef receiver, Envelope handle)
boolean	hasMessages()	Indicates whether this queue is non-empty.
int	numberOfMessages()	Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently.
java.util.Queue<Envelope>	queue()

Methods inherited from interface akka.dispatch.QueueBasedMessageQueue

cleanUp

Method Detail

controlQueue

java.util.Queue<Envelope> controlQueue()

dequeue

Envelope dequeue()

Description copied from interface: MessageQueue

Try to dequeue the next message from this queue, return null failing that.

Specified by:

dequeue in interface MessageQueue

Returns:

(undocumented)

enqueue

void enqueue(ActorRef receiver,
             Envelope handle)

Specified by:

enqueue in interface MessageQueue

hasMessages

boolean hasMessages()

Description copied from interface: MessageQueue

Indicates whether this queue is non-empty.

Specified by:

hasMessages in interface MessageQueue

Specified by:

hasMessages in interface QueueBasedMessageQueue

Returns:

(undocumented)

numberOfMessages

int numberOfMessages()

Description copied from interface: MessageQueue

Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently. Do not use this for testing for presence of messages, use hasMessages instead.

Specified by:

numberOfMessages in interface MessageQueue

Specified by:

numberOfMessages in interface QueueBasedMessageQueue

Returns:

(undocumented)

queue

java.util.Queue<Envelope> queue()

Specified by:

queue in interface QueueBasedMessageQueue