Class CompositeQueue

java.lang.Object
com.swiftmq.swiftlet.queue.AbstractQueue
com.swiftmq.impl.queue.standard.composite.CompositeQueue
public class CompositeQueue extends com.swiftmq.swiftlet.queue.AbstractQueue

  • Field Summary

    Fields inherited from class com.swiftmq.swiftlet.queue.AbstractQueue

    ACTIVESTANDBY, AS_MESSAGE, cleanUpInterval, consumerMode, EXCLUSIVE, flowController, maxMessages, NON_PERSISTENT, persistenceMode, PERSISTENT, receiverCount, SHARED, temporary

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompositeQueue(SwiftletContext ctx, com.swiftmq.mgmt.Entity compositeQueueEntity)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    commit(Object object)
     
    void
    commit(Object object, com.swiftmq.jms.XidImpl xid)
     
    void
    commit(Object object, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
     
    Object
    createPullTransaction()
     
    Object
    createPushTransaction()
     
    void
    deleteContent()
     
    boolean
    hasReceiver(com.swiftmq.jms.MessageImpl message)
     
    void
    lockQueue(Object object)
     
    void
    prepare(Object object, com.swiftmq.jms.XidImpl xid)
     
    void
    putMessage(Object object, com.swiftmq.jms.MessageImpl message)
     
    void
    rollback(Object object, boolean setRedelivered)
     
    void
    rollback(Object object, boolean setRedelivered, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
     
    void
    rollback(Object object, com.swiftmq.jms.XidImpl xid, boolean setRedelivered)
     
    void
    setCompositeStoreTransaction(Object object, com.swiftmq.swiftlet.store.CompositeStoreTransaction ct)
     
    void
    startQueue()
     
    void
    stopQueue()
     
    void
    unlockQueue(Object object, boolean markAsyncActive)
     

    Methods inherited from class com.swiftmq.swiftlet.queue.AbstractQueue

    acknowledgeMessage, acknowledgeMessage, acknowledgeMessages, addWireTapSubscriber, buildPreparedTransaction, cleanUpExpiredMessages, createView, decReceiverCount, deleteView, flushAccounting, getAndResetAverageLatency, getCacheSize, getCacheSizeKB, getCleanUpInterval, getCompositeStoreTransaction, getConsumedTotal, getConsumerMode, getConsumingRate, getCurrentCacheSizeKB, getCurrentCacheSizeMessages, getExpiredMessage, getFlowController, getIndexEntry, getLocalName, getMaxMessages, getMessage, getMessage, getMessage, getMessage, getMessage, getMessage, getMessageByIndex, getMonitorAlertThreshold, getNumberQueueMessages, getPersistenceMode, getProducedTotal, getProducingRate, getQueueIndex, getQueueIndex, getQueueName, getQueueReceiverListener, getReceiverCount, incReceiverCount, isAccounting, isRunning, isTemporary, moveToTransaction, moveToTransaction, moveToTransactionReturnSize, moveToTransactionReturnSize, receiverClosed, registerMessageProcessor, removeMessageByIndex, removeMessages, removeWireTapSubscriber, resetCounters, selectBaseQueue, setCleanUpInterval, setConsumerMode, setFlowController, setLocalName, setMaxMessages, setPersistenceMode, setQueueName, setQueueReceiverListener, setTemporary, startAccounting, stopAccounting, timeoutMessageProcessor, unmarkAsyncActive, unregisterMessageProcessor

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • CompositeQueue

      public CompositeQueue(SwiftletContext ctx, com.swiftmq.mgmt.Entity compositeQueueEntity)

  • Method Details

    • lockQueue

      public void lockQueue(Object object)
      Overrides:
      lockQueue in class com.swiftmq.swiftlet.queue.AbstractQueue

    • unlockQueue

      public void unlockQueue(Object object, boolean markAsyncActive)
      Overrides:
      unlockQueue in class com.swiftmq.swiftlet.queue.AbstractQueue

    • setCompositeStoreTransaction

      public void setCompositeStoreTransaction(Object object, com.swiftmq.swiftlet.store.CompositeStoreTransaction ct)
      Overrides:
      setCompositeStoreTransaction in class com.swiftmq.swiftlet.queue.AbstractQueue

    • hasReceiver

      public boolean hasReceiver(com.swiftmq.jms.MessageImpl message)
      Specified by:
      hasReceiver in class com.swiftmq.swiftlet.queue.AbstractQueue

    • createPushTransaction

      public Object createPushTransaction() throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      createPushTransaction in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • createPullTransaction

      public Object createPullTransaction() throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      createPullTransaction in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • putMessage

      public void putMessage(Object object, com.swiftmq.jms.MessageImpl message) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      putMessage in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • prepare

      public void prepare(Object object, com.swiftmq.jms.XidImpl xid) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      prepare in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • commit

      public void commit(Object object, com.swiftmq.jms.XidImpl xid) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      commit in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • commit

      public void commit(Object object) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      commit in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • commit

      public void commit(Object object, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
      Specified by:
      commit in class com.swiftmq.swiftlet.queue.AbstractQueue

    • rollback

      public void rollback(Object object, com.swiftmq.jms.XidImpl xid, boolean setRedelivered) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      rollback in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • rollback

      public void rollback(Object object, boolean setRedelivered) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      rollback in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • rollback

      public void rollback(Object object, boolean setRedelivered, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
      Specified by:
      rollback in class com.swiftmq.swiftlet.queue.AbstractQueue

    • deleteContent

      public void deleteContent() throws com.swiftmq.swiftlet.queue.QueueException
      Overrides:
      deleteContent in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • startQueue

      public void startQueue() throws com.swiftmq.swiftlet.queue.QueueException
      Overrides:
      startQueue in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException

    • stopQueue

      public void stopQueue() throws com.swiftmq.swiftlet.queue.QueueException
      Overrides:
      stopQueue in class com.swiftmq.swiftlet.queue.AbstractQueue
      Throws:
      com.swiftmq.swiftlet.queue.QueueException