Package org.apache.activemq.ra

Class LocalAndXATransaction

java.lang.Object
org.apache.activemq.ra.LocalAndXATransaction
All Implemented Interfaces:
jakarta.resource.spi.LocalTransaction, XAResource
public class LocalAndXATransaction extends Object implements XAResource, jakarta.resource.spi.LocalTransaction
Used to provide a LocalTransaction and XAResource to a JMS session.

  • Constructor Details

    • LocalAndXATransaction

      public LocalAndXATransaction(org.apache.activemq.TransactionContext transactionContext)

  • Method Details

    • setTransactionContext

      public void setTransactionContext(org.apache.activemq.TransactionContext transactionContext)

    • setInManagedTx

      public void setInManagedTx(boolean inManagedTx) throws jakarta.jms.JMSException
      Throws:
      jakarta.jms.JMSException

    • begin

      public void begin() throws jakarta.resource.ResourceException
      Specified by:
      begin in interface jakarta.resource.spi.LocalTransaction
      Throws:
      jakarta.resource.ResourceException

    • commit

      public void commit() throws jakarta.resource.ResourceException
      Specified by:
      commit in interface jakarta.resource.spi.LocalTransaction
      Throws:
      jakarta.resource.ResourceException

    • rollback

      public void rollback() throws jakarta.resource.ResourceException
      Specified by:
      rollback in interface jakarta.resource.spi.LocalTransaction
      Throws:
      jakarta.resource.ResourceException

    • commit

      public void commit(Xid arg0, boolean arg1) throws XAException
      Specified by:
      commit in interface XAResource
      Throws:
      XAException

    • end

      public void end(Xid arg0, int arg1) throws XAException
      Specified by:
      end in interface XAResource
      Throws:
      XAException

    • forget

      public void forget(Xid arg0) throws XAException
      Specified by:
      forget in interface XAResource
      Throws:
      XAException

    • getTransactionTimeout

      public int getTransactionTimeout() throws XAException
      Specified by:
      getTransactionTimeout in interface XAResource
      Throws:
      XAException

    • isSameRM

      public boolean isSameRM(XAResource xaresource) throws XAException
      Specified by:
      isSameRM in interface XAResource
      Throws:
      XAException

    • prepare

      public int prepare(Xid arg0) throws XAException
      Specified by:
      prepare in interface XAResource
      Throws:
      XAException

    • recover

      public Xid[] recover(int arg0) throws XAException
      Specified by:
      recover in interface XAResource
      Throws:
      XAException

    • rollback

      public void rollback(Xid arg0) throws XAException
      Specified by:
      rollback in interface XAResource
      Throws:
      XAException

    • setTransactionTimeout

      public boolean setTransactionTimeout(int arg0) throws XAException
      Specified by:
      setTransactionTimeout in interface XAResource
      Throws:
      XAException

    • start

      public void start(Xid arg0, int arg1) throws XAException
      Specified by:
      start in interface XAResource
      Throws:
      XAException

    • isInManagedTx

      public boolean isInManagedTx()

    • cleanup

      public void cleanup()

    • toString

      public String toString()
      Overrides:
      toString in class Object