Package org.apache.pekko.dispatch
Class UnboundedControlAwareMailbox.MessageQueue
- java.lang.Object
-
- org.apache.pekko.dispatch.UnboundedControlAwareMailbox.MessageQueue
-
- All Implemented Interfaces:
java.io.Serializable
,ControlAwareMessageQueueSemantics
,MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
,UnboundedControlAwareMessageQueueSemantics
,UnboundedMessageQueueSemantics
- Enclosing class:
- UnboundedControlAwareMailbox
public static class UnboundedControlAwareMailbox.MessageQueue extends java.lang.Object implements UnboundedControlAwareMessageQueueSemantics, java.io.Serializable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MessageQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Queue<Envelope>
controlQueue()
java.util.Queue<Envelope>
queue()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.pekko.dispatch.ControlAwareMessageQueueSemantics
dequeue, enqueue, hasMessages, numberOfMessages
-
Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp
-
-
-
-
Method Detail
-
controlQueue
public java.util.Queue<Envelope> controlQueue()
- Specified by:
controlQueue
in interfaceControlAwareMessageQueueSemantics
-
queue
public java.util.Queue<Envelope> queue()
- Specified by:
queue
in interfaceControlAwareMessageQueueSemantics
- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
-