public interface TransactionServices
Modifier and Type | Method | Description |
---|---|---|
void |
commit(byte[] tId) |
Called by Participant endpoint to commit tx/subordinate branch
|
byte[] |
enlistResource(javax.transaction.xa.XAResource resource,
javax.transaction.xa.Xid xid) |
Called by Registraion Service during register call in order to enlist WSAT XAResource
(this is essentially the WSAT participant EPR wrapper that is serialized for recovery)
and return branchqual in order to create RegisterResponseType
|
int |
getExpires() |
The tx timeout/ttl value
|
byte[] |
getGlobalTransactionId() |
The tx id of the tx on this thread
|
javax.xml.ws.EndpointReference |
getParentReference(javax.transaction.xa.Xid xid) |
Called from Participant service to get the Coordinator(PortType) for this Xid
|
javax.transaction.xa.Xid |
importTransaction(int timeout,
byte[] tId) |
Called by server tube (WSATServerHelper) to infect thread with tx
|
java.lang.String |
prepare(byte[] tId) |
Called by Participant endpoint to prepare tx/subordinate branch
|
void |
registerSynchronization(javax.transaction.Synchronization synchronization,
javax.transaction.xa.Xid xid) |
Called by Registration service to register a volatile participant
|
void |
replayCompletion(java.lang.String tId,
javax.transaction.xa.XAResource xaResource) |
Called by Coordinator replay operation
Bottom-up recovery call, as in JTS, a hint to resend
|
void |
rollback(byte[] tId) |
Called by Participant endpoint to prepare tx/subordinate branch
|
byte[] getGlobalTransactionId()
byte[] enlistResource(javax.transaction.xa.XAResource resource, javax.transaction.xa.Xid xid) throws WSATException
resource
- (WSAT)XAResourcexid
- XidWSATException
- any error during enlist as WSAT GatewayRMvoid registerSynchronization(javax.transaction.Synchronization synchronization, javax.transaction.xa.Xid xid) throws WSATException
synchronization
- javax.transaction.Synchronizationxid
- XidWSATException
- wsatXAResourceint getExpires()
javax.transaction.xa.Xid importTransaction(int timeout, byte[] tId) throws WSATException
timeout
- timeout/ttltId
- byte[]WSATException
- wsatXAResourcejava.lang.String prepare(byte[] tId) throws WSATException
tId
- byte[]WSATException
- wsatXAResourcevoid commit(byte[] tId) throws WSATException
tId
- byte[]WSATException
- wsatXAResourcevoid rollback(byte[] tId) throws WSATException
tId
- byte[]WSATException
- wsatXAResourcevoid replayCompletion(java.lang.String tId, javax.transaction.xa.XAResource xaResource) throws WSATException
tId
- byte[]xaResource
- (WSAT)XAResourceWSATException
- wsatXAResourcejavax.xml.ws.EndpointReference getParentReference(javax.transaction.xa.Xid xid)
xid
- Xid