io.smallrye.reactive.messaging.kafka.impl

Class RecordQueue<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.ArrayDeque<T>

io.smallrye.reactive.messaging.kafka.impl.RecordQueue<T>

All Implemented Interfaces:

Serializable, Cloneable, Iterable<T>, Collection<T>, Deque<T>, Queue<T>

public class RecordQueue<T>
extends ArrayDeque<T>

Stores the records coming from Kafka. Only a few operations are supported: addAll(Iterable), clear(), size() and poll().

The access is guarded by the monitor lock.

Ths initial capacity is 2 * batch size.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RecordQueue(int capacityHint)

Method Summary

Modifier and Type	Method and Description
boolean	add(T item)
boolean	addAll(Collection<? extends T> c)
void	addAll(Iterable<T> iterable)
void	clear()
boolean	offer(T item)
T	peek()
T	poll()
boolean	remove(Object o)
int	size()

Methods inherited from class java.util.ArrayDeque

addFirst, addLast, clone, contains, descendingIterator, element, getFirst, getLast, isEmpty, iterator, offerFirst, offerLast, peekFirst, peekLast, pollFirst, pollLast, pop, push, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, spliterator, toArray, toArray

Methods inherited from class java.util.AbstractCollection

containsAll, removeAll, retainAll, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

RecordQueue

public RecordQueue(int capacityHint)

Method Detail

addAll

public boolean addAll(Collection<? extends T> c)

Specified by:

addAll in interface Collection<T>

Overrides:

addAll in class AbstractCollection<T>

addAll

public void addAll(Iterable<T> iterable)

add

public boolean add(T item)

Specified by:

add in interface Collection<T>

Specified by:

add in interface Deque<T>

Specified by:

add in interface Queue<T>

Overrides:

add in class ArrayDeque<T>

offer

public boolean offer(T item)

Specified by:

offer in interface Deque<T>

Specified by:

offer in interface Queue<T>

Overrides:

offer in class ArrayDeque<T>

poll

public T poll()

Specified by:

poll in interface Deque<T>

Specified by:

poll in interface Queue<T>

Overrides:

poll in class ArrayDeque<T>

peek

public T peek()

Specified by:

peek in interface Deque<T>

Specified by:

peek in interface Queue<T>

Overrides:

peek in class ArrayDeque<T>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<T>

Specified by:

remove in interface Deque<T>

Overrides:

remove in class ArrayDeque<T>

size

public int size()

Specified by:

size in interface Collection<T>

Specified by:

size in interface Deque<T>

Overrides:

size in class ArrayDeque<T>

clear

public void clear()

Specified by:

clear in interface Collection<T>

Overrides:

clear in class ArrayDeque<T>