Class ClusteredQueue

java.lang.Object
com.swiftmq.swiftlet.queue.AbstractQueue
com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
public class ClusteredQueue 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
    ClusteredQueue(SwiftletContext ctx, DispatchPolicy dispatchPolicy)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    commit(Object txId)
     
    void
    commit(Object txId, com.swiftmq.jms.XidImpl xid)
     
    void
    commit(Object txId, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
     
    Object
    createPullTransaction()
     
    Object
    createPushTransaction()
     
    void
    deleteContent()
     
    com.swiftmq.swiftlet.store.CompositeStoreTransaction
    getCompositeStoreTransaction(Object txId)
     
    boolean
    hasReceiver(com.swiftmq.jms.MessageImpl message)
     
    void
    lockQueue(Object txId)
     
    void
    prepare(Object txId, com.swiftmq.jms.XidImpl xid)
     
    void
    putMessage(Object txId, com.swiftmq.jms.MessageImpl message)
     
    void
    rollback(Object txId, boolean b)
     
    void
    rollback(Object txId, boolean b, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
     
    void
    rollback(Object txId, com.swiftmq.jms.XidImpl xid, boolean b)
     
    com.swiftmq.swiftlet.queue.AbstractQueue
    selectBaseQueue()
     
    void
    setCompositeStoreTransaction(Object txId, com.swiftmq.swiftlet.store.CompositeStoreTransaction ct)
     
    void
    startQueue()
     
    void
    stopQueue()
     
    String
    toString()
     
    void
    unlockQueue(Object txId, boolean markAsyncActive)
     
    void
    unmarkAsyncActive(Object txId)
     

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

    acknowledgeMessage, acknowledgeMessage, acknowledgeMessages, addWireTapSubscriber, buildPreparedTransaction, cleanUpExpiredMessages, createView, decReceiverCount, deleteView, flushAccounting, getAndResetAverageLatency, getCacheSize, getCacheSizeKB, getCleanUpInterval, 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, setCleanUpInterval, setConsumerMode, setFlowController, setLocalName, setMaxMessages, setPersistenceMode, setQueueName, setQueueReceiverListener, setTemporary, startAccounting, stopAccounting, timeoutMessageProcessor, unregisterMessageProcessor

    Methods inherited from class Object

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

  • Constructor Details

  • Method Details

    • selectBaseQueue

      public com.swiftmq.swiftlet.queue.AbstractQueue selectBaseQueue()
      Overrides:
      selectBaseQueue 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

    • lockQueue

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

    • unlockQueue

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

    • unmarkAsyncActive

      public void unmarkAsyncActive(Object txId)
      Overrides:
      unmarkAsyncActive in class com.swiftmq.swiftlet.queue.AbstractQueue

    • setCompositeStoreTransaction

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

    • getCompositeStoreTransaction

      public com.swiftmq.swiftlet.store.CompositeStoreTransaction getCompositeStoreTransaction(Object txId)
      Overrides:
      getCompositeStoreTransaction in class com.swiftmq.swiftlet.queue.AbstractQueue

    • 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

    • 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

    • putMessage

      public void putMessage(Object txId, 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

    • commit

      public void commit(Object txId) 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 txId, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
      Specified by:
      commit in class com.swiftmq.swiftlet.queue.AbstractQueue

    • rollback

      public void rollback(Object txId, boolean b) 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 txId, boolean b, com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
      Specified by:
      rollback in class com.swiftmq.swiftlet.queue.AbstractQueue

    • prepare

      public void prepare(Object txId, 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 txId, 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

    • rollback

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

    • 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

    • toString

      public String toString()
      Overrides:
      toString in class Object