Interface LimitQueueCallback
-
- All Superinterfaces:
QueueCallback
- All Known Implementing Classes:
LimitedQueueCallback
public interface LimitQueueCallback extends QueueCallback
The limit callback forBlockingRecordQueue
.- Since:
- 0.8.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
setLimitHandler(LimitHandler limitHandler)
Sets the handler to be invoked when the queue limit is reached.void
setQueue(BlockingRecordQueue queue)
Sets theBlockingRecordQueue
to be passed to theLimitHandler
.-
Methods inherited from interface io.streamthoughts.azkarra.api.events.callback.QueueCallback
onClosed, onQueued
-
-
-
-
Method Detail
-
setLimitHandler
void setLimitHandler(LimitHandler limitHandler)
Sets the handler to be invoked when the queue limit is reached.- Parameters:
limitHandler
- theLimitHandler
.
-
setQueue
void setQueue(BlockingRecordQueue queue)
Sets theBlockingRecordQueue
to be passed to theLimitHandler
.- Parameters:
queue
- theBlockingRecordQueue
.
-
-