public static class UnboundedMailbox.MessageQueue extends java.util.concurrent.ConcurrentLinkedQueue<Envelope> implements UnboundedQueueBasedMessageQueue
Constructor and Description |
---|
MessageQueue() |
Modifier and Type | Method and Description |
---|---|
java.util.Queue<Envelope> |
queue() |
add, addAll, contains, isEmpty, iterator, offer, peek, poll, remove, size, spliterator, toArray, toArray
containsAll, removeAll, retainAll, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dequeue, enqueue
cleanUp, hasMessages, numberOfMessages
public final java.util.Queue<Envelope> queue()
queue
in interface QueueBasedMessageQueue