Uses of Interface
io.streamthoughts.azkarra.api.events.callback.QueueCallback
-
Packages that use QueueCallback Package Description io.streamthoughts.azkarra.api.events io.streamthoughts.azkarra.api.events.callback -
-
Uses of QueueCallback in io.streamthoughts.azkarra.api.events
Methods in io.streamthoughts.azkarra.api.events with parameters of type QueueCallback Modifier and Type Method Description void
BasicBlockingRecordQueue. setQueueCallback(QueueCallback callback)
Sets the callback to be executed when a new record is queued or the queue is closed.void
BlockingRecordQueue. setQueueCallback(QueueCallback callback)
Sets the callback to be executed when a new record is queued or the queue is closed.void
DelegateBlockingRecordQueue. setQueueCallback(QueueCallback callback)
Sets the callback to be executed when a new record is queued or the queue is closed. -
Uses of QueueCallback in io.streamthoughts.azkarra.api.events.callback
Subinterfaces of QueueCallback in io.streamthoughts.azkarra.api.events.callback Modifier and Type Interface Description interface
LimitQueueCallback
The limit callback forBlockingRecordQueue
.Classes in io.streamthoughts.azkarra.api.events.callback that implement QueueCallback Modifier and Type Class Description class
LimitedQueueCallback
The defaultLimitQueueCallback
implementation.
-