Class ListenerNotificationQueue
- java.lang.Object
-
- gov.usgs.earthquake.util.RoundRobinQueue<T>
-
- gov.usgs.earthquake.util.RoundRobinBlockingQueue<ListenerNotification>
-
- gov.usgs.earthquake.distribution.roundrobinnotifier.ListenerNotificationQueue
-
- All Implemented Interfaces:
java.lang.Iterable<ListenerNotification>
,java.util.Collection<ListenerNotification>
,java.util.concurrent.BlockingQueue<ListenerNotification>
,java.util.Queue<ListenerNotification>
public class ListenerNotificationQueue extends RoundRobinBlockingQueue<ListenerNotification>
A round-robin blocking queue for ListenerNotification objects.
-
-
Constructor Summary
Constructors Constructor Description ListenerNotificationQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.String
getQueueId(ListenerNotification notification)
Round robin per source + type.-
Methods inherited from class gov.usgs.earthquake.util.RoundRobinBlockingQueue
add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take
-
Methods inherited from class gov.usgs.earthquake.util.RoundRobinQueue
addAll, clear, containsAll, element, isEmpty, iterator, peek, poll, remove, removeAll, retainAll, size, toArray, toArray, toList
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Method Detail
-
getQueueId
protected java.lang.String getQueueId(ListenerNotification notification)
Round robin per source + type.- Overrides:
getQueueId
in classRoundRobinQueue<ListenerNotification>
- Parameters:
notification
- the object being added.- Returns:
- id of the queue where object should be added.
-
-