private static final class JtaLocalTransactionStore.JtaLocalEhcacheXAResource extends java.lang.Object implements EhcacheXAResource
Modifier and Type | Field and Description |
---|---|
private TransactionController |
transactionController |
private TransactionID |
transactionId |
private TransactionManagerLookup |
transactionManagerLookup |
Modifier | Constructor and Description |
---|---|
private |
JtaLocalEhcacheXAResource(TransactionController transactionController,
TransactionID transactionId,
TransactionManagerLookup transactionManagerLookup) |
Modifier and Type | Method and Description |
---|---|
void |
addTwoPcExecutionListener(XAExecutionListener listener)
Add a listener which will be called back according to the 2PC lifecycle
|
void |
commit(javax.transaction.xa.Xid xid,
boolean onePhase) |
XATransactionContext |
createTransactionContext()
Obtain the already associated
XATransactionContext with the current Transaction,
or create a new one should none be there yet. |
void |
end(javax.transaction.xa.Xid xid,
int flag) |
void |
forget(javax.transaction.xa.Xid xid) |
java.lang.String |
getCacheName()
Getter to the name of the cache wrapped by this XAResource
|
XATransactionContext |
getCurrentTransactionContext()
Gets the current
XATransactionContext associated with this resource |
int |
getTransactionTimeout() |
boolean |
isSameRM(javax.transaction.xa.XAResource xaResource) |
int |
prepare(javax.transaction.xa.Xid xid) |
javax.transaction.xa.Xid[] |
recover(int flags) |
void |
rollback(javax.transaction.xa.Xid xid) |
boolean |
setTransactionTimeout(int timeout) |
void |
start(javax.transaction.xa.Xid xid,
int flag) |
java.lang.String |
toString() |
private final TransactionController transactionController
private final TransactionID transactionId
private final TransactionManagerLookup transactionManagerLookup
private JtaLocalEhcacheXAResource(TransactionController transactionController, TransactionID transactionId, TransactionManagerLookup transactionManagerLookup)
public void commit(javax.transaction.xa.Xid xid, boolean onePhase) throws javax.transaction.xa.XAException
commit
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void end(javax.transaction.xa.Xid xid, int flag) throws javax.transaction.xa.XAException
end
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void forget(javax.transaction.xa.Xid xid) throws javax.transaction.xa.XAException
forget
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public int getTransactionTimeout() throws javax.transaction.xa.XAException
getTransactionTimeout
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean isSameRM(javax.transaction.xa.XAResource xaResource) throws javax.transaction.xa.XAException
isSameRM
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public int prepare(javax.transaction.xa.Xid xid) throws javax.transaction.xa.XAException
prepare
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public javax.transaction.xa.Xid[] recover(int flags) throws javax.transaction.xa.XAException
recover
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void rollback(javax.transaction.xa.Xid xid) throws javax.transaction.xa.XAException
rollback
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean setTransactionTimeout(int timeout) throws javax.transaction.xa.XAException
setTransactionTimeout
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void start(javax.transaction.xa.Xid xid, int flag) throws javax.transaction.xa.XAException
start
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void addTwoPcExecutionListener(XAExecutionListener listener)
EhcacheXAResource
addTwoPcExecutionListener
in interface EhcacheXAResource
listener
- the XAExecutionListenerpublic java.lang.String getCacheName()
EhcacheXAResource
getCacheName
in interface EhcacheXAResource
Ehcache.getName()
valuepublic XATransactionContext createTransactionContext() throws javax.transaction.SystemException, javax.transaction.RollbackException
EhcacheXAResource
XATransactionContext
with the current Transaction,
or create a new one should none be there yet.createTransactionContext
in interface EhcacheXAResource
XATransactionContext
javax.transaction.SystemException
- Thrown if the associated transaction manager encounters an unexpected error condition.javax.transaction.RollbackException
- Thrown if the resource has to be enlisted with the transaction, while it is marked for rollback only.public XATransactionContext getCurrentTransactionContext()
EhcacheXAResource
XATransactionContext
associated with this resourcegetCurrentTransactionContext
in interface EhcacheXAResource
XATransactionContext
, or null if nonepublic java.lang.String toString()
toString
in class java.lang.Object