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:: Serializable, Iterable<Envelope>, Collection<Envelope>, BlockingQueue<Envelope>, Queue<Envelope>, BoundedMessageQueueSemantics, BoundedQueueBasedMessageQueue, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue

Enclosing class:: BoundedMailbox

public static class BoundedMailbox.MessageQueue extends LinkedBlockingQueue<Envelope> implements BoundedQueueBasedMessageQueue

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

MessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)
Method Summary

Modifier and Type

Method

Description

final scala.concurrent.duration.FiniteDuration

pushTimeOut()

final 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.util.AbstractQueue
add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection
containsAll, isEmpty

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue
add

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 java.util.Queue
element, remove

Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages

Constructor Details
- MessageQueue
  
  public MessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)
Method Details
- pushTimeOut
  
  public final scala.concurrent.duration.FiniteDuration pushTimeOut()
  
  Specified by:
  
  pushTimeOut in interface BoundedMessageQueueSemantics
- queue
  
  public final BlockingQueue<Envelope> queue()
  
  Specified by:
  
  queue in interface BoundedQueueBasedMessageQueue
  
  Specified by:
  
  queue in interface QueueBasedMessageQueue