public class TransactionContext extends Object implements XAResource
Session
,
QueueSession
,
TopicSession
,
XASession
Modifier and Type | Field and Description |
---|---|
static String |
xaErrorCodeMarker |
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
Constructor and Description |
---|
TransactionContext() |
TransactionContext(ActiveMQConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
addSynchronization(Synchronization s) |
void |
begin()
Start a local transaction.
|
void |
cleanup() |
void |
commit()
Commits all work done in this transaction and releases any locks
currently held.
|
void |
commit(Xid xid,
boolean onePhase) |
void |
end(Xid xid,
int flags) |
void |
forget(Xid xid) |
ActiveMQConnection |
getConnection() |
LocalTransactionEventListener |
getLocalTransactionEventListener() |
protected String |
getResourceManagerId() |
TransactionId |
getTransactionId() |
int |
getTransactionTimeout() |
boolean |
isInLocalTransaction() |
boolean |
isInTransaction() |
boolean |
isInXATransaction() |
boolean |
isSameRM(XAResource xaResource) |
int |
prepare(Xid xid) |
Xid[] |
recover(int flag) |
void |
rollback()
Rolls back any work done in this transaction and releases any locks
currently held.
|
void |
rollback(Xid xid) |
ActiveMQConnection |
setConnection(ActiveMQConnection connection) |
void |
setLocalTransactionEventListener(LocalTransactionEventListener localTransactionEventListener)
Used by the resource adapter to listen to transaction events.
|
void |
setRollbackOnly(boolean val) |
boolean |
setTransactionTimeout(int seconds) |
void |
start(Xid xid,
int flags)
Associates a transaction with the resource.
|
String |
toString() |
public static final String xaErrorCodeMarker
public TransactionContext()
public TransactionContext(ActiveMQConnection connection)
public boolean isInXATransaction()
public void setRollbackOnly(boolean val)
public boolean isInLocalTransaction()
public boolean isInTransaction()
public LocalTransactionEventListener getLocalTransactionEventListener()
public void setLocalTransactionEventListener(LocalTransactionEventListener localTransactionEventListener)
localTransactionEventListener
- The localTransactionEventListener to
set.public void addSynchronization(Synchronization s)
public TransactionId getTransactionId()
public void begin() throws JMSException
JMSException
- on internal errorpublic void rollback() throws JMSException
JMSException
- if the JMS provider fails to roll back the
transaction due to some internal error.IllegalStateException
- if the method is not called by a
transacted session.public void commit() throws JMSException
JMSException
- if the JMS provider fails to commit the transaction
due to some internal error.IllegalStateException
- if the method is not called by a
transacted session.public void start(Xid xid, int flags) throws XAException
start
in interface XAResource
XAException
public void end(Xid xid, int flags) throws XAException
end
in interface XAResource
XAException
public int prepare(Xid xid) throws XAException
prepare
in interface XAResource
XAException
public void rollback(Xid xid) throws XAException
rollback
in interface XAResource
XAException
public void commit(Xid xid, boolean onePhase) throws XAException
commit
in interface XAResource
XAException
public void forget(Xid xid) throws XAException
forget
in interface XAResource
XAException
public boolean isSameRM(XAResource xaResource) throws XAException
isSameRM
in interface XAResource
XAException
public Xid[] recover(int flag) throws XAException
recover
in interface XAResource
XAException
public int getTransactionTimeout() throws XAException
getTransactionTimeout
in interface XAResource
XAException
public boolean setTransactionTimeout(int seconds) throws XAException
setTransactionTimeout
in interface XAResource
XAException
protected String getResourceManagerId() throws JMSException
JMSException
public ActiveMQConnection getConnection()
public ActiveMQConnection setConnection(ActiveMQConnection connection)
public void cleanup()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.