Wombat::MamaQueueMonitorCallback

More…

#include <MamaQueueMonitorCallback.h>

Public Functions

Detailed Description

class Wombat::MamaQueueMonitorCallback;

Receive callbacks when certain conditions for the MamaQueue are met.

Currently only one callback is defined which is invoked when the specified size limit on the MamaQueue is exceeded.

Public Functions Documentation

function ~MamaQueueMonitorCallback

inline virtual ~MamaQueueMonitorCallback()

function onHighWatermarkExceeded

virtual void onHighWatermarkExceeded(
    MamaQueue * queue,
    size_t size,
    void * closure
) =0

Parameters:

• queue Pointer to the queue for which this callback was invoked.
• size The number of events on the queue if supported; otherwise 0.
• closure User supplied data when the callback object was registered.

Callback invoked if an upper size limit has been specified for a queue and that limit has been exceeded.

function onLowWatermark

virtual void onLowWatermark(
    MamaQueue * queue,
    size_t size,
    void * closure
) =0

Parameters:

• queue Pointer to the queue for which this callback was invoked.
• size The number of events on the queue.
• closure User supplied data when the callback object was registered.

Callback when low water mark is reached. Only supported by Wombat TCP middleware.

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