Package com.swiftmq.impl.topic.standard

Class TopicTransaction

java.lang.Object
com.swiftmq.impl.topic.standard.TopicTransaction
public class TopicTransaction extends Object

  • Constructor Details

  • Method Details

    • setParentTx

      public void setParentTx(CompositeStoreTransaction parentTx)

    • lockQueues

      public void lockQueues()

    • unlockQueues

      public void unlockQueues()

    • setTransactionId

      public void setTransactionId(int transactionId)

    • getTransactionId

      protected int getTransactionId()

    • setTopicSubscriberTransaction

      protected void setTopicSubscriberTransaction(int brokerSubscriberId, TopicSubscriberTransaction topicSubscriberTransaction)

    • getTopicSubscriberTransaction

      protected TopicSubscriberTransaction getTopicSubscriberTransaction(int brokerSubscriberId)

    • prepare

      protected void prepare(XidImpl globalTxId) throws Exception
      Throws:
      Exception

    • commit

      protected long commit(XidImpl globalTxId) throws Exception
      Throws:
      Exception

    • rollback

      protected void rollback(XidImpl globalTxId) throws Exception
      Throws:
      Exception

    • commit

      protected long commit() throws Exception
      Throws:
      Exception

    • commit

      protected void commit(AsyncCompletionCallback callback)

    • rollback

      protected void rollback() throws Exception
      Throws:
      Exception

    • rollback

      protected void rollback(AsyncCompletionCallback callback)

    • toString

      public String toString()
      Overrides:
      toString in class Object