Package com.swiftmq.impl.topic.standard

Class TopicSubscriberTransaction

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

  • Constructor Details

    • TopicSubscriberTransaction

      protected TopicSubscriberTransaction(TopicSubscription topicSubscription, QueuePushTransaction transaction, String destination)

  • Method Details

    • isPersistentMessageIncluded

      public boolean isPersistentMessageIncluded()

    • setPersistentMessageIncluded

      public void setPersistentMessageIncluded(boolean persistentMessageIncluded)

    • getTopicSubscription

      protected TopicSubscription getTopicSubscription()

    • getTransaction

      public QueuePushTransaction getTransaction()

    • publish

      protected void publish(MessageImpl message) throws Exception
      Throws:
      Exception

    • prepare

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

    • commit

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

    • commit

      protected long commit() throws Exception
      Throws:
      Exception

    • commit

      protected void commit(AsyncCompletionCallback callback)

    • rollback

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

    • rollback

      protected void rollback() throws Exception
      Throws:
      Exception

    • rollback

      protected void rollback(AsyncCompletionCallback callback)

    • toString

      public String toString()
      Overrides:
      toString in class Object