Package gov.usgs.earthquake.util
Class NotificationEventBlockingQueue
- java.lang.Object
-
- gov.usgs.earthquake.util.RoundRobinQueue<T>
-
- gov.usgs.earthquake.util.RoundRobinBlockingQueue<NotificationEvent>
-
- gov.usgs.earthquake.util.NotificationEventBlockingQueue
-
- All Implemented Interfaces:
java.lang.Iterable<NotificationEvent>
,java.util.Collection<NotificationEvent>
,java.util.concurrent.BlockingQueue<NotificationEvent>
,java.util.Queue<NotificationEvent>
public class NotificationEventBlockingQueue extends RoundRobinBlockingQueue<NotificationEvent>
Preliminary implementation for priority queuing products.
-
-
Constructor Summary
Constructors Constructor Description NotificationEventBlockingQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.String
getQueueId(NotificationEvent event)
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(NotificationEvent event)
Round robin per source + type.- Overrides:
getQueueId
in classRoundRobinQueue<NotificationEvent>
- Parameters:
event
- the object being added.- Returns:
- id of the queue where object should be added.
-
-