Package org.apache.pekko.dispatch
Class BoundedMailbox.MessageQueue
- java.lang.Object
-
- java.util.AbstractCollection<E>
-
- java.util.AbstractQueue<E>
-
- java.util.concurrent.LinkedBlockingQueue<Envelope>
-
- org.apache.pekko.dispatch.BoundedMailbox.MessageQueue
-
- All Implemented Interfaces:
java.io.Serializable
,java.lang.Iterable<Envelope>
,java.util.Collection<Envelope>
,java.util.concurrent.BlockingQueue<Envelope>
,java.util.Queue<Envelope>
,BoundedMessageQueueSemantics
,BoundedQueueBasedMessageQueue
,MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
- Enclosing class:
- BoundedMailbox
public static class BoundedMailbox.MessageQueue extends java.util.concurrent.LinkedBlockingQueue<Envelope> implements BoundedQueueBasedMessageQueue
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.concurrent.duration.FiniteDuration
pushTimeOut()
java.util.concurrent.BlockingQueue<Envelope>
queue()
-
Methods inherited from class java.util.concurrent.LinkedBlockingQueue
clear, contains, drainTo, drainTo, forEach, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, removeIf, retainAll, size, spliterator, take, toArray, toArray, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue
dequeue, enqueue
-
Methods inherited from interface java.util.Collection
addAll, containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray
-
Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
-
-
-
-
Method Detail
-
pushTimeOut
public final scala.concurrent.duration.FiniteDuration pushTimeOut()
- Specified by:
pushTimeOut
in interfaceBoundedMessageQueueSemantics
-
queue
public final java.util.concurrent.BlockingQueue<Envelope> queue()
- Specified by:
queue
in interfaceBoundedQueueBasedMessageQueue
- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
-