org.apache.activemq.artemis.core.server.impl

Class QueueConsumersImpl<T extends PriorityAware>

java.lang.Object

org.apache.activemq.artemis.core.server.impl.QueueConsumersImpl<T>

Type Parameters:

T - The type this class may hold, this is generic as can be anything that extends PriorityAware, but intent is this is the QueueImpl:ConsumerHolder.

All Implemented Interfaces:

Iterable<T>, Iterator<T>, QueueConsumers<T>, RepeatableIterator<T>, ResettableIterator<T>

public class QueueConsumersImpl<T extends PriorityAware>
extends Object
implements QueueConsumers<T>

This class's purpose is to hold the consumers. CopyOnWriteArraySet is used as the underlying collection to the PriorityCollection, as it is concurrent safe, but also lock less for a read path, which is our HOT path. Also it was the underlying collection previously used in QueueImpl, before we abstracted it out to support priority consumers. There can only be one resettable iterable view, A new iterable view is created on modification, this is to keep the read HOT path performent, BUT the iterable view changes only after reset so changes in the underlying collection are only seen after a reset, All other iterators created by iterators() method are not reset-able and are created on delegating iterator().

Constructor Summary

Constructors

Constructor and Description
QueueConsumersImpl()

Method Summary

Modifier and Type	Method and Description
boolean	add(T t)
void	forEach(Consumer<? super T> action)
Set<Integer>	getPriorites()
boolean	hasNext()
boolean	isEmpty()
Iterator<T>	iterator()
T	next()
boolean	remove(T t)
void	repeat() If the current value should repeat.
void	reset() Resets the iterator so you can re-iterate over all elements.
int	size()
Spliterator<T>	spliterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

QueueConsumersImpl

public QueueConsumersImpl()

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T extends PriorityAware>

next

public T next()

Specified by:

next in interface Iterator<T extends PriorityAware>

repeat

public void repeat()

Description copied from interface: RepeatableIterator

If the current value should repeat.

Specified by:

repeat in interface RepeatableIterator<T extends PriorityAware>

reset

public void reset()

Description copied from interface: ResettableIterator

Resets the iterator so you can re-iterate over all elements.

Specified by:

reset in interface ResettableIterator<T extends PriorityAware>

add

public boolean add(T t)

Specified by:

add in interface QueueConsumers<T extends PriorityAware>

remove

public boolean remove(T t)

Specified by:

remove in interface QueueConsumers<T extends PriorityAware>

size

public int size()

Specified by:

size in interface QueueConsumers<T extends PriorityAware>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface QueueConsumers<T extends PriorityAware>

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T extends PriorityAware>

forEach

public void forEach(Consumer<? super T> action)

Specified by:

forEach in interface Iterable<T extends PriorityAware>

spliterator

public Spliterator<T> spliterator()

Specified by:

spliterator in interface Iterable<T extends PriorityAware>

getPriorites

public Set<Integer> getPriorites()

Specified by:

getPriorites in interface QueueConsumers<T extends PriorityAware>