com::wombat::mama::MamaQueue

Public Functions

Public Attributes

Public Functions Documentation

function getPointerVal

inline long getPointerVal()

function MamaQueue

inline MamaQueue()

function create

native void create(
    MamaBridge bridge
)

function createUsingNative

native void createUsingNative(
    MamaBridge bridge,
    Object nativeQueue
)

function destroy

native void destroy()

Exceptions:

• MamaException will be thrown if there are open objects.

Destroy the queue, this function should only be called if there are no open objects against the queue. Use one of the other destroy functions to block until all objects have been cleaned up.

function destroyWait

native void destroyWait()

Destroy a queue. Note that the queue can only be destroyed if all of the objects created on it, (timers, subscriptions etc), have been destroyed. This function will block until all of the objects have been destroyed and will then destroy the queue.

function destroyTimedWait

native void destroyTimedWait(
    long timeout
)

Parameters:

• timeout The time to block for in milliseconds.

Exceptions:

• MamaException will be thrown if the timeout elapses.

Destroy a queue. Note that the queue can only be destroyed if all of the objects created on it, (timers, subscriptions etc), have been destroyed. This function will block until all of the objects have been destroyed and will then destroy the queue.

function dispatch

native void dispatch()

function stopDispatch

native void stopDispatch()

function enqueueEvent

native void enqueueEvent(
    MamaQueueEventCallback callback,
    Object closure
)

function setQueueMonitorCallback

native void setQueueMonitorCallback(
    MamaQueueMonitorCallback callback
)

function setHighWatermark

native void setHighWatermark(
    long highWatermark
)

function getHighwatermark

native long getHighwatermark()

function setLowWatermark

native void setLowWatermark(
    long lowWatermark
)

function getLowWatermark

native long getLowWatermark()

function setQueueName

native void setQueueName(
    String queueName
)

function getQueueName

native String getQueueName()

function getQueueBridgeName

native String getQueueBridgeName()

function getEventCount

native long getEventCount()

Public Attributes Documentation

variable reuseableMsg

MamaMsg reuseableMsg = null;

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