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

Class LimitedQueueCallback

java.lang.Object

io.streamthoughts.azkarra.api.events.callback.LimitedQueueCallback

All Implemented Interfaces:

LimitQueueCallback, QueueCallback

public class LimitedQueueCallback
extends Object
implements LimitQueueCallback

The default LimitQueueCallback implementation.

Since:

0.8.0

Constructor Summary

Constructors

Constructor	Description
LimitedQueueCallback(int limit)	Creates a new LimitedQueueCallback instance.

Method Summary

Modifier and Type	Method	Description
void	onClosed()	Invokes when the queue is closed.
void	onQueued()	Invokes when a new record is queued.
void	setLimitHandler(LimitHandler limitHandler)	Sets the handler to be invoked when the queue limit is reached.
void	setQueue(BlockingRecordQueue queue)	Sets the BlockingRecordQueue to be passed to the LimitHandler.

Methods inherited from class java.lang.Object

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

Constructor Detail

LimitedQueueCallback

public LimitedQueueCallback(int limit)

Creates a new LimitedQueueCallback instance.

Parameters:

limit - the queue limit.

Method Detail

setLimitHandler

public void setLimitHandler(LimitHandler limitHandler)

Sets the handler to be invoked when the queue limit is reached.

Specified by:

setLimitHandler in interface LimitQueueCallback

Parameters:

limitHandler - the LimitHandler.

setQueue

public void setQueue(BlockingRecordQueue queue)

Sets the BlockingRecordQueue to be passed to the LimitHandler.

Specified by:

setQueue in interface LimitQueueCallback

Parameters:

queue - the BlockingRecordQueue.

onQueued

public void onQueued()

Invokes when a new record is queued.

Specified by:

onQueued in interface QueueCallback

onClosed

public void onClosed()

Invokes when the queue is closed.

Specified by:

onClosed in interface QueueCallback