com.wombat.mama
public class MamaQueue extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
MamaMsg |
reuseableMsg |
Constructor and Description |
---|
MamaQueue() |
Modifier and Type | Method and Description |
---|---|
void |
create(MamaBridge bridge) |
void |
createUsingNative(MamaBridge bridge,
java.lang.Object nativeQueue) |
void |
destroy()
Destroy the queue, this function should only be called if there are no
open objects against the queue.
|
void |
destroyTimedWait(long timeout)
Destroy a queue.
|
void |
destroyWait()
Destroy a queue.
|
void |
dispatch() |
void |
enqueueEvent(MamaQueueEventCallback callback,
java.lang.Object closure) |
long |
getEventCount() |
long |
getHighwatermark() |
long |
getLowWatermark() |
long |
getPointerVal() |
java.lang.String |
getQueueBridgeName() |
java.lang.String |
getQueueName() |
void |
setHighWatermark(long highWatermark) |
void |
setLowWatermark(long lowWatermark) |
void |
setQueueMonitorCallback(MamaQueueMonitorCallback callback) |
void |
setQueueName(java.lang.String queueName) |
void |
stopDispatch() |
public MamaMsg reuseableMsg
public long getPointerVal()
public void create(MamaBridge bridge)
public void createUsingNative(MamaBridge bridge, java.lang.Object nativeQueue)
public void destroy()
MamaException
- will be thrown if there are open objects.public void destroyWait()
public void destroyTimedWait(long timeout)
timeout
- The time to block for in milliseconds.MamaException
- will be thrown if the timeout elapses.public void dispatch()
public void stopDispatch()
public void enqueueEvent(MamaQueueEventCallback callback, java.lang.Object closure)
public void setQueueMonitorCallback(MamaQueueMonitorCallback callback)
public void setHighWatermark(long highWatermark)
public long getHighwatermark()
public void setLowWatermark(long lowWatermark)
public long getLowWatermark()
public void setQueueName(java.lang.String queueName)
public java.lang.String getQueueName()
public java.lang.String getQueueBridgeName()
public long getEventCount()
Copyright 2011 NYSE Technologies