public class ManagedTransactionContext extends org.apache.activemq.TransactionContext
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
Constructor and Description |
---|
ManagedTransactionContext(org.apache.activemq.TransactionContext sharedContext) |
Modifier and Type | Method and Description |
---|---|
void |
addSynchronization(Synchronization s) |
void |
begin() |
void |
commit() |
void |
commit(Xid xid,
boolean onePhase) |
void |
end(Xid xid,
int flags) |
void |
forget(Xid xid) |
org.apache.activemq.command.TransactionId |
getTransactionId() |
int |
getTransactionTimeout() |
boolean |
isInLocalTransaction() |
boolean |
isInTransaction() |
boolean |
isInXATransaction() |
boolean |
isSameRM(XAResource xaResource) |
int |
prepare(Xid xid) |
Xid[] |
recover(int flag) |
void |
rollback() |
void |
rollback(Xid xid) |
boolean |
setTransactionTimeout(int seconds) |
void |
setUseSharedTxContext(boolean enable) |
void |
start(Xid xid,
int flags) |
public ManagedTransactionContext(org.apache.activemq.TransactionContext sharedContext)
public void setUseSharedTxContext(boolean enable) throws JMSException
JMSException
public void begin() throws JMSException
begin
in class org.apache.activemq.TransactionContext
JMSException
public void commit() throws JMSException
commit
in class org.apache.activemq.TransactionContext
JMSException
public void commit(Xid xid, boolean onePhase) throws XAException
commit
in interface XAResource
commit
in class org.apache.activemq.TransactionContext
XAException
public void end(Xid xid, int flags) throws XAException
end
in interface XAResource
end
in class org.apache.activemq.TransactionContext
XAException
public void forget(Xid xid) throws XAException
forget
in interface XAResource
forget
in class org.apache.activemq.TransactionContext
XAException
public org.apache.activemq.command.TransactionId getTransactionId()
getTransactionId
in class org.apache.activemq.TransactionContext
public int getTransactionTimeout() throws XAException
getTransactionTimeout
in interface XAResource
getTransactionTimeout
in class org.apache.activemq.TransactionContext
XAException
public boolean isInLocalTransaction()
isInLocalTransaction
in class org.apache.activemq.TransactionContext
public boolean isInXATransaction()
isInXATransaction
in class org.apache.activemq.TransactionContext
public boolean isInTransaction()
isInTransaction
in class org.apache.activemq.TransactionContext
public boolean isSameRM(XAResource xaResource) throws XAException
isSameRM
in interface XAResource
isSameRM
in class org.apache.activemq.TransactionContext
XAException
public int prepare(Xid xid) throws XAException
prepare
in interface XAResource
prepare
in class org.apache.activemq.TransactionContext
XAException
public Xid[] recover(int flag) throws XAException
recover
in interface XAResource
recover
in class org.apache.activemq.TransactionContext
XAException
public void rollback() throws JMSException
rollback
in class org.apache.activemq.TransactionContext
JMSException
public void rollback(Xid xid) throws XAException
rollback
in interface XAResource
rollback
in class org.apache.activemq.TransactionContext
XAException
public boolean setTransactionTimeout(int seconds) throws XAException
setTransactionTimeout
in interface XAResource
setTransactionTimeout
in class org.apache.activemq.TransactionContext
XAException
public void start(Xid xid, int flags) throws XAException
start
in interface XAResource
start
in class org.apache.activemq.TransactionContext
XAException
public void addSynchronization(Synchronization s)
addSynchronization
in class org.apache.activemq.TransactionContext
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.