Wombat::MamaQueueGroup

A class for distributing events across multiple queues in a round robin fashion.

Inherits from IDisposable

Public Functions

Public Functions Documentation

function MamaQueueGroup

MamaQueueGroup(
    MamaBridge bridgeImpl,
    int queueCount
)

Construct a queue manager with given number of queues/threads

Parameters:

• bridgeImpl The mama bridge.
• queueCount The number of queues in the group.

function destroy

void destroy()

Destroy the queue group and destroy all the queues without waiting, this is equivalent to disposing the class.

function destroyWait

void destroyWait()

Destroy the queue group and destroy all the queues waiting on each queue, this is equivalent to disposing the class.

function Dispose

void Dispose()

Dispose managed and unmanaged resources. This will destroy all the queues without waiting for them to shutdown.

function start

void start()

Start dispatching on all queues.

function stop

void stop()

Stop dispatching on all queues.

function getNextQueue

MamaQueue getNextQueue()

This function will return the next queue since it was called last or the first queue in the group if this is the first time that it has been called. Note that when all queues have been returned it will go back to the start of the array.

function getQueueByIndex

MamaQueue getQueueByIndex(
    int index
)

This function will return the queue in this queue group at the given index specifically.

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