Uses of Interface
io.streamthoughts.azkarra.api.events.BlockingRecordQueue

Packages that use BlockingRecordQueue

Package	Description
io.streamthoughts.azkarra.api.events
io.streamthoughts.azkarra.api.events.callback

Uses of BlockingRecordQueue in io.streamthoughts.azkarra.api.events

Classes in io.streamthoughts.azkarra.api.events that implement BlockingRecordQueue

Modifier and Type	Class	Description
class	BasicBlockingRecordQueue<K,V>	A simple BlockingRecordQueue backed by a BlockingQueue.
class	DelegateBlockingRecordQueue<K,V>	A delegating BlockingRecordQueue that can be used to easily override some methods.

Methods in io.streamthoughts.azkarra.api.events with parameters of type BlockingRecordQueue

Modifier and Type	Method	Description
<K,V> void	LimitHandler.onLimitReached(BlockingRecordQueue<K,V> queue)	Invokes when the limit of a BlockingRecordQueue is reached.
void	EventStreamPipe.onOpen(BlockingRecordQueue<K,V> queue)	Set the queue from which records are produced.

Constructors in io.streamthoughts.azkarra.api.events with parameters of type BlockingRecordQueue

Constructor	Description
DelegateBlockingRecordQueue(BlockingRecordQueue<K,V> delegate)
EventStream(String type, BlockingRecordQueue<K,V> queue)	Creates a new EventStream instance.

Uses of BlockingRecordQueue in io.streamthoughts.azkarra.api.events.callback

Methods in io.streamthoughts.azkarra.api.events.callback with parameters of type BlockingRecordQueue

Modifier and Type	Method	Description
void	LimitedQueueCallback.setQueue(BlockingRecordQueue queue)	Sets the BlockingRecordQueue to be passed to the LimitHandler.
void	LimitQueueCallback.setQueue(BlockingRecordQueue queue)	Sets the BlockingRecordQueue to be passed to the LimitHandler.