Package org.infinispan.transaction.xa

Class XaTransactionTable

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.infinispan.transaction.impl.TransactionTable

        org.infinispan.transaction.impl.TransactionTable.CompletedTransactionStatus

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.lang.String cacheName  
      protected RecoveryManager recoveryManager  
      protected java.util.concurrent.ConcurrentMap<javax.transaction.xa.Xid,​LocalXaTransaction> xid2LocalTx  

      • Fields inherited from class org.infinispan.transaction.impl.TransactionTable

        CACHE_STOPPED_TOPOLOGY_ID, clustered, commandsFactory, configuration, partitionHandlingManager, rpcManager, running, txCoordinator

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void commit​(javax.transaction.xa.Xid externalXid, boolean isOnePhase)  
      void enlist​(javax.transaction.Transaction transaction, org.infinispan.transaction.impl.LocalTransaction ltx)  
      void enlistClientTransaction​(javax.transaction.Transaction transaction, org.infinispan.transaction.impl.LocalTransaction localTransaction)  
      LocalXaTransaction getLocalTransaction​(javax.transaction.xa.Xid xid)  
      int getLocalTxCount()  
      int prepare​(javax.transaction.xa.Xid externalXid)  
      boolean removeLocalTransaction​(org.infinispan.transaction.impl.LocalTransaction localTx)
      Removes the TransactionXaAdapter corresponding to the given tx.
      void startXidMapping()  

      • Methods inherited from class org.infinispan.transaction.impl.TransactionTable

        afterCompletion, beforeCompletion, cleanupLeaverTransactions, containRemoteTx, containsLocalTx, failureCompletingTransaction, getCompletedTransactionStatus, getGlobalTransaction, getLocalGlobalTransaction, getLocalTransaction, getLocalTransaction, getLocalTransactions, getMinTopologyId, getOrCreateLocalTransaction, getOrCreateLocalTransaction, getOrCreateRemoteTransaction, getRemoteGlobalTransaction, getRemoteTransaction, getRemoteTransactions, getRemoteTxCount, isTransactionCompleted, localTransactionPrepared, markTransactionCompleted, onTopologyChange, onViewChange, recalculateMinTopologyIdIfNeeded, releaseLocksForCompletedTransaction, remoteTransactionCommitted, remoteTransactionPrepared, remoteTransactionRollback, removeRemoteTransaction, start

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • cacheName

        protected java.lang.String cacheName

      • xid2LocalTx

        protected java.util.concurrent.ConcurrentMap<javax.transaction.xa.Xid,​LocalXaTransaction> xid2LocalTx

    • Constructor Detail

      • XaTransactionTable

        public XaTransactionTable()

    • Method Detail

      • startXidMapping

        public void startXidMapping()

      • removeLocalTransaction

        public boolean removeLocalTransaction​(org.infinispan.transaction.impl.LocalTransaction localTx)
        Description copied from class: org.infinispan.transaction.impl.TransactionTable
        Removes the TransactionXaAdapter corresponding to the given tx. Returns true if such an tx exists.
        Overrides:
        removeLocalTransaction in class org.infinispan.transaction.impl.TransactionTable

      • getLocalTransaction

        public LocalXaTransaction getLocalTransaction​(javax.transaction.xa.Xid xid)

      • enlist

        public void enlist​(javax.transaction.Transaction transaction,
                   org.infinispan.transaction.impl.LocalTransaction ltx)
        Overrides:
        enlist in class org.infinispan.transaction.impl.TransactionTable

      • enlistClientTransaction

        public void enlistClientTransaction​(javax.transaction.Transaction transaction,
                                    org.infinispan.transaction.impl.LocalTransaction localTransaction)
        Overrides:
        enlistClientTransaction in class org.infinispan.transaction.impl.TransactionTable

      • getLocalTxCount

        public int getLocalTxCount()
        Overrides:
        getLocalTxCount in class org.infinispan.transaction.impl.TransactionTable

      • prepare

        public int prepare​(javax.transaction.xa.Xid externalXid)
            throws javax.transaction.xa.XAException
        Throws:
        javax.transaction.xa.XAException

      • commit

        public void commit​(javax.transaction.xa.Xid externalXid,
                   boolean isOnePhase)
            throws javax.transaction.xa.XAException
        Throws:
        javax.transaction.xa.XAException