UnboundedControlAwareMailbox.MessageQueue

java.lang.Object

org.apache.pekko.dispatch.UnboundedControlAwareMailbox.MessageQueue

All Implemented Interfaces:: Serializable, ControlAwareMessageQueueSemantics, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, UnboundedControlAwareMessageQueueSemantics, UnboundedMessageQueueSemantics

Enclosing class:: UnboundedControlAwareMailbox

public static class UnboundedControlAwareMailbox.MessageQueue extends Object implements UnboundedControlAwareMessageQueueSemantics, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

MessageQueue()
Method Summary

Modifier and Type

Method

Description

Queue<Envelope>

controlQueue()

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

Constructor Details
- MessageQueue
  
  public MessageQueue()
Method Details
- controlQueue
  
  public Queue<Envelope> controlQueue()
  
  Specified by:
  
  controlQueue in interface ControlAwareMessageQueueSemantics
- queue
  
  public Queue<Envelope> queue()
  
  Specified by:
  
  queue in interface ControlAwareMessageQueueSemantics
  
  Specified by:
  
  queue in interface QueueBasedMessageQueue