Class MamaQueue


  • public class MamaQueue
    extends java.lang.Object
    • Field Detail

      • reuseableMsg

        public MamaMsg reuseableMsg
    • Constructor Detail

      • MamaQueue

        public MamaQueue()
    • Method Detail

      • getPointerVal

        public long getPointerVal()
      • create

        public void create​(MamaBridge bridge)
      • createUsingNative

        public void createUsingNative​(MamaBridge bridge,
                                      java.lang.Object nativeQueue)
      • destroy

        public void destroy()
        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.
        Throws:
        MamaException - will be thrown if there are open objects.
      • destroyWait

        public 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.
      • destroyTimedWait

        public void destroyTimedWait​(long timeout)
        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.
        Parameters:
        timeout - The time to block for in milliseconds.
        Throws:
        MamaException - will be thrown if the timeout elapses.
      • dispatch

        public void dispatch()
      • stopDispatch

        public void stopDispatch()
      • setHighWatermark

        public void setHighWatermark​(long highWatermark)
      • getHighwatermark

        public long getHighwatermark()
      • setLowWatermark

        public void setLowWatermark​(long lowWatermark)
      • getLowWatermark

        public long getLowWatermark()
      • setQueueName

        public void setQueueName​(java.lang.String queueName)
      • getQueueName

        public java.lang.String getQueueName()
      • getQueueBridgeName

        public java.lang.String getQueueBridgeName()
      • getEventCount

        public long getEventCount()