org.opendaylight.controller.cluster.common.actor

Class MeteredBoundedMailbox.MeteredMessageQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingDeque<akka.dispatch.Envelope>

akka.dispatch.BoundedDequeBasedMailbox.MessageQueue

org.opendaylight.controller.cluster.common.actor.MeteredBoundedMailbox.MeteredMessageQueue

All Implemented Interfaces:

akka.dispatch.BoundedDequeBasedMessageQueue, akka.dispatch.BoundedDequeBasedMessageQueueSemantics, akka.dispatch.BoundedMessageQueueSemantics, akka.dispatch.DequeBasedMessageQueue, akka.dispatch.DequeBasedMessageQueueSemantics, akka.dispatch.MessageQueue, akka.dispatch.MultipleConsumerSemantics, akka.dispatch.QueueBasedMessageQueue, Serializable, Iterable<akka.dispatch.Envelope>, Collection<akka.dispatch.Envelope>, BlockingDeque<akka.dispatch.Envelope>, BlockingQueue<akka.dispatch.Envelope>, Deque<akka.dispatch.Envelope>, Queue<akka.dispatch.Envelope>

Enclosing class:

MeteredBoundedMailbox

public static class MeteredBoundedMailbox.MeteredMessageQueue
extends akka.dispatch.BoundedDequeBasedMailbox.MessageQueue

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MeteredMessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)

Method Summary

Methods inherited from class akka.dispatch.BoundedDequeBasedMailbox.MessageQueue

cleanUp, dequeue, enqueue, enqueueFirst, hasMessages, numberOfMessages, pushTimeOut, queue

Methods inherited from class java.util.concurrent.LinkedBlockingDeque

add, addFirst, addLast, clear, contains, descendingIterator, drainTo, drainTo, element, getFirst, getLast, iterator, offer, offer, offerFirst, offerFirst, offerLast, offerLast, peek, peekFirst, peekLast, poll, poll, pollFirst, pollFirst, pollLast, pollLast, pop, push, put, putFirst, putLast, remainingCapacity, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, size, spliterator, take, takeFirst, takeLast, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

addAll

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.dispatch.BoundedDequeBasedMessageQueue

$init$

Methods inherited from interface akka.dispatch.QueueBasedMessageQueue

$init$

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

MeteredMessageQueue

public MeteredMessageQueue(int capacity,
                           scala.concurrent.duration.FiniteDuration pushTimeOut)