Class EventQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingQueue<E>

org.eclipse.jetty.toolchain.test.EventQueue<E>

Type Parameters:

E - the type of entry in this EventQueue

All Implemented Interfaces:

Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>

public class EventQueue<E>
extends LinkedBlockingQueue<E>

Event Queue for capturing potential events within a testing scenario.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	DEBUG

Constructor Summary

Constructors

Constructor	Description
EventQueue()

Method Summary

Modifier and Type	Method	Description
boolean	add(E o)
void	awaitEventCount(int expectedEventCount, int timeoutDuration, TimeUnit timeoutUnit)	Await a specific event count
boolean	offer(E o)
void	shutdown()	Shutdown the queue.

Methods inherited from class LinkedBlockingQueue

clear, contains, drainTo, drainTo, forEach, iterator, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, removeIf, retainAll, size, spliterator, take, toArray, toArray, toString

Methods inherited from class AbstractQueue

addAll, element, remove

Methods inherited from class AbstractCollection

containsAll, isEmpty

Methods inherited from class Object

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

Methods inherited from interface Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray

Methods inherited from interface Queue

element, remove

Field Details

DEBUG

public static final boolean DEBUG

See Also:

• Constant Field Values

Constructor Details

EventQueue

public EventQueue()

Method Details

add

public boolean add(E o)

Specified by:

add in interface BlockingQueue<E>

Specified by:

add in interface Collection<E>

Specified by:

add in interface Queue<E>

Overrides:

add in class AbstractQueue<E>

awaitEventCount

public void awaitEventCount(int expectedEventCount,
 int timeoutDuration,
 TimeUnit timeoutUnit)
                     throws TimeoutException,
InterruptedException

Await a specific event count

Parameters:

expectedEventCount - the number of events to wait for

timeoutDuration - the timeout duration

timeoutUnit - the timeout unit

Throws:

TimeoutException - if timeout while waiting for the event count

InterruptedException - if await was interrupted

offer

public boolean offer(E o)

Specified by:

offer in interface BlockingQueue<E>

Specified by:

offer in interface Queue<E>

Overrides:

offer in class LinkedBlockingQueue<E>

shutdown

public void shutdown()

Shutdown the queue.