org.activemq.ra
Class RATransactionContext
java.lang.Object
org.activemq.TransactionContext
org.activemq.ra.RATransactionContext
- All Implemented Interfaces:
- XAResource
public class RATransactionContext
- extends org.activemq.TransactionContext
Allows us to switch between using a shared transaction context,
or using a local transaction context.
- Version:
- $Revision: 1.1.1.1 $
Fields inherited from interface javax.transaction.xa.XAResource |
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY |
Methods inherited from class org.activemq.TransactionContext |
getConnection, getLocalTransactionEventListener, setLocalTransactionEventListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RATransactionContext
public RATransactionContext(org.activemq.TransactionContext sharedContext)
setUseSharedTxContext
public void setUseSharedTxContext(boolean enable)
throws JMSException
- Throws:
JMSException
addSession
public void addSession(org.activemq.ActiveMQSession session)
- Overrides:
addSession
in class org.activemq.TransactionContext
removeSession
public void removeSession(org.activemq.ActiveMQSession session)
- Overrides:
removeSession
in class org.activemq.TransactionContext
begin
public void begin()
throws JMSException
- Overrides:
begin
in class org.activemq.TransactionContext
- Throws:
JMSException
commit
public void commit()
throws JMSException
- Overrides:
commit
in class org.activemq.TransactionContext
- Throws:
JMSException
commit
public void commit(Xid xid,
boolean onePhase)
throws XAException
- Specified by:
commit
in interface XAResource
- Overrides:
commit
in class org.activemq.TransactionContext
- Throws:
XAException
end
public void end(Xid xid,
int flags)
throws XAException
- Specified by:
end
in interface XAResource
- Overrides:
end
in class org.activemq.TransactionContext
- Throws:
XAException
forget
public void forget(Xid xid)
throws XAException
- Specified by:
forget
in interface XAResource
- Overrides:
forget
in class org.activemq.TransactionContext
- Throws:
XAException
getTransactionId
public Object getTransactionId()
- Overrides:
getTransactionId
in class org.activemq.TransactionContext
getTransactionTimeout
public int getTransactionTimeout()
throws XAException
- Specified by:
getTransactionTimeout
in interface XAResource
- Overrides:
getTransactionTimeout
in class org.activemq.TransactionContext
- Throws:
XAException
isInLocalTransaction
public boolean isInLocalTransaction()
- Overrides:
isInLocalTransaction
in class org.activemq.TransactionContext
isInXATransaction
public boolean isInXATransaction()
- Overrides:
isInXATransaction
in class org.activemq.TransactionContext
isSameRM
public boolean isSameRM(XAResource xaResource)
throws XAException
- Specified by:
isSameRM
in interface XAResource
- Overrides:
isSameRM
in class org.activemq.TransactionContext
- Throws:
XAException
prepare
public int prepare(Xid xid)
throws XAException
- Specified by:
prepare
in interface XAResource
- Overrides:
prepare
in class org.activemq.TransactionContext
- Throws:
XAException
recover
public Xid[] recover(int flag)
throws XAException
- Specified by:
recover
in interface XAResource
- Overrides:
recover
in class org.activemq.TransactionContext
- Throws:
XAException
rollback
public void rollback()
throws JMSException
- Overrides:
rollback
in class org.activemq.TransactionContext
- Throws:
JMSException
rollback
public void rollback(Xid xid)
throws XAException
- Specified by:
rollback
in interface XAResource
- Overrides:
rollback
in class org.activemq.TransactionContext
- Throws:
XAException
setTransactionTimeout
public boolean setTransactionTimeout(int seconds)
throws XAException
- Specified by:
setTransactionTimeout
in interface XAResource
- Overrides:
setTransactionTimeout
in class org.activemq.TransactionContext
- Throws:
XAException
start
public void start(Xid xid,
int flags)
throws XAException
- Specified by:
start
in interface XAResource
- Overrides:
start
in class org.activemq.TransactionContext
- Throws:
XAException
Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.