Uses of Interface
io.streamthoughts.azkarra.api.events.LimitHandler
-
Packages that use LimitHandler Package Description io.streamthoughts.azkarra.api.events io.streamthoughts.azkarra.api.events.callback -
-
Uses of LimitHandler in io.streamthoughts.azkarra.api.events
Fields in io.streamthoughts.azkarra.api.events declared as LimitHandler Modifier and Type Field Description static LimitHandler
LimitHandlers. NO_OP
Methods in io.streamthoughts.azkarra.api.events that return LimitHandler Modifier and Type Method Description static LimitHandler
LimitHandlers. dropHeadOnLimitReached()
static LimitHandler
LimitHandlers. logAndContinueOnLimitReached()
static LimitHandler
LimitHandlers. throwExceptionOnLimitReached()
Methods in io.streamthoughts.azkarra.api.events with parameters of type LimitHandler Modifier and Type Method Description protected void
EventStreamSupport. setDefaultEventQueueLimitHandler(LimitHandler limitHandler)
Sets the defaultLimitHandler
that will be used for creatingEventStream
.void
BasicBlockingRecordQueue. setLimitHandler(LimitHandler limitHandler)
Sets the handler to be invoked when the limit queue is reached.void
BlockingRecordQueue. setLimitHandler(LimitHandler handler)
Sets the handler to be invoked when the limit queue is reached.void
DelegateBlockingRecordQueue. setLimitHandler(LimitHandler handler)
Sets the handler to be invoked when the limit queue is reached.EventStream.Builder
EventStream.Builder. withQueueLimitHandler(LimitHandler queueLimitHandler)
Constructors in io.streamthoughts.azkarra.api.events with parameters of type LimitHandler Constructor Description BasicBlockingRecordQueue(int queueSizeLimit, Duration maxBlockDuration, LimitHandler limitHandler)
Creates a newBasicBlockingRecordQueue
instance. -
Uses of LimitHandler in io.streamthoughts.azkarra.api.events.callback
Methods in io.streamthoughts.azkarra.api.events.callback with parameters of type LimitHandler Modifier and Type Method Description void
LimitedQueueCallback. setLimitHandler(LimitHandler limitHandler)
Sets the handler to be invoked when the queue limit is reached.void
LimitQueueCallback. setLimitHandler(LimitHandler limitHandler)
Sets the handler to be invoked when the queue limit is reached.
-