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:

Iterable<NotificationEvent>, Collection<NotificationEvent>, BlockingQueue<NotificationEvent>, Queue<NotificationEvent>

public class NotificationEventBlockingQueue
extends RoundRobinBlockingQueue<NotificationEvent>

Preliminary implementation for priority queuing products.

Constructor Summary

Constructors

Constructor	Description
NotificationEventBlockingQueue()

Method Summary

Modifier and Type	Method	Description
protected 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

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Queue

element, peek, poll, remove

Constructor Details

NotificationEventBlockingQueue

public NotificationEventBlockingQueue()

Method Details

getQueueId

protected String getQueueId(NotificationEvent event)

Round robin per source + type.

Overrides:

getQueueId in class RoundRobinQueue<NotificationEvent>

Parameters:

event - the object being added.

Returns:

id of the queue where object should be added.