| java.lang.Object org.jboss.mq.pm.TxManager
TxManager | public class TxManager implements Recoverable(Code) | | This class allows provides the base for user supplied persistence packages.
author: Hiram Chirino (Cojonudo14@hotmail.com) author: Paul Kendall (paul.kendall@orion.co.nz) author: Adrian Brock version: $Revision: 57198 $ |
Inner Class :class GlobalXID implements Runnable | |
Inner Class :public static class PreparedInfo | |
Method Summary | |
public void | addPostCommitTask(Tx txId, Runnable task) | public void | addPostRollbackTask(Tx txId, Runnable task) | void | addPreparedTx(Tx txId, Xid xid, boolean inDoubt) | final public void | commitTx(Tx txId) Commit the transaction to the persistent store. | final public void | commitTx(ConnectionToken dc, Object xid) Commit the transaction to the persistent store. | final public Tx | createTx() Create and return a unique transaction id. | public Tx | createTx(ConnectionToken dc, Object xid) Create and return a unique transaction id. | final public Tx | getPrepared(ConnectionToken dc, Object xid) Return the local transaction id for a distributed transaction id. | public Map | getPreparedTransactions() | public void | markPrepared(ConnectionToken dc, Object xid, Tx txId) | public Xid[] | recover(ConnectionToken dc, int flags) | public void | restoreTx(Tx txId) | public void | rollbackTx(Tx txId) Rollback the transaction. | final public void | rollbackTx(ConnectionToken dc, Object xid) |
globalToLocal | ConcurrentHashMap globalToLocal(Code) | | Maps Global transactions to local transactions
|
prepared | ConcurrentHashMap prepared(Code) | | Prepared Transactions Map>
|
addPostCommitTask | public void addPostCommitTask(Tx txId, Runnable task) throws JMSException(Code) | | Add an operation for after a commit
Parameters: txId - the transaction Parameters: task - the task throws: JMSException - for any error |
addPostRollbackTask | public void addPostRollbackTask(Tx txId, Runnable task) throws JMSException(Code) | | Add an operation for after a rollback
Parameters: txId - the transaction Parameters: task - the task throws: JMSException - for any error |
addPreparedTx | void addPreparedTx(Tx txId, Xid xid, boolean inDoubt) throws JMSException(Code) | | Add a prepared transactions
Parameters: txId - the transaction id Parameters: xid - the xid Parameters: inDoubt - whether it is in doubt throws: JMSException - for any error |
commitTx | final public void commitTx(Tx txId) throws JMSException(Code) | | Commit the transaction to the persistent store.
Parameters: txId - the transaction exception: JMSException - for any error |
commitTx | final public void commitTx(ConnectionToken dc, Object xid) throws JMSException(Code) | | Commit the transaction to the persistent store.
Parameters: dc - the connection token Parameters: xid - the transaction exception: JMSException - for any error |
createTx | final public Tx createTx() throws JMSException(Code) | | Create and return a unique transaction id.
the transaction id exception: JMSException - for any error |
createTx | public Tx createTx(ConnectionToken dc, Object xid) throws JMSException(Code) | | Create and return a unique transaction id. Given a distributed connection
and a transaction id object, allocate a unique local transaction id if
the remote id is not already known.
Parameters: dc - the connection token Parameters: xid - the xid the transaction exception: JMSException - for any error |
getPrepared | final public Tx getPrepared(ConnectionToken dc, Object xid) throws JMSException(Code) | | Return the local transaction id for a distributed transaction id.
Parameters: dc - the connection Parameters: xid - the transaction id The Prepared transaction exception: javax.jms.JMSException - Description of Exception |
getPreparedTransactions | public Map getPreparedTransactions()(Code) | | Get the prepared transactions
|
markPrepared | public void markPrepared(ConnectionToken dc, Object xid, Tx txId) throws JMSException(Code) | | Mark the transaction branch as prepared
Parameters: dc - the connection token Parameters: xid - the xid Parameters: txId - the transaction throws: JMSException - for any error |
restoreTx | public void restoreTx(Tx txId) throws JMSException(Code) | | Restore a prepared transaction
Parameters: txId - the transaction id throws: JMSException - for any error |
rollbackTx | public void rollbackTx(Tx txId) throws JMSException(Code) | | Rollback the transaction.
Parameters: txId - the transaction exception: JMSException - for any error |
rollbackTx | final public void rollbackTx(ConnectionToken dc, Object xid) throws JMSException(Code) | | Rollback the transaction
Parameters: dc - the connection token Parameters: xid - the transaction exception: JMSException - for any error |
|
|