com::wombat::mama::MamaQueueMonitorCallback

Public Functions

	Name
void	onHighWatermarkExceeded(MamaQueue queue, long size)
void	onLowWatermark(MamaQueue queue, long size)

Detailed Description

class com::wombat::mama::MamaQueueMonitorCallback;

Definition of the callback methods enabling event queue monitoring. Receiving callbacks when either the high watermark or the low watermark are exceeded. Not all middlewares will support the concept of both high and low watermarks. Concrete instances of this interface are registered with an event queue using the MamaQueue.setQueueMonitorCallback ().

Public Functions Documentation

function onHighWatermarkExceeded

void onHighWatermarkExceeded(
    MamaQueue queue,
    long size
)

Parameters:

queue The MamaQueue for which the high watermark was exceeded.
size The number of outstanding events on the event queue.

Called when the specified high watermark threshold for the event queue has been exceeded.

function onLowWatermark

void onLowWatermark(
    MamaQueue queue,
    long size
)

Parameters:

queue The MamaQueue for which the high watermark was exceeded.
size The number of outstanding events on the event queue.

Called when the number of events on the event queue go below the specified low watermark. This is currently only supported for the WombatTCP middleware.

Updated on 2023-03-31 at 15:29:43 +0100