public class WSATHelper<T> extends Object
Modifier and Type | Field and Description |
---|---|
static WSATHelper |
V10 |
static WSATHelper |
V11 |
Modifier | Constructor and Description |
---|---|
protected |
WSATHelper() |
Modifier and Type | Method and Description |
---|---|
static String |
assignUUID() |
void |
beforeCompletion(EndpointReference epr,
Xid xid,
WSATSynchronization wsatSynchronization)
beforeCompletion call on volatile participant
|
void |
commit(EndpointReference epr,
Xid xid,
WSATXAResource wsatXAResource)
Unlike rollback, Xids are not added to the durable participant XAResource map during commit as prepare must always be
called in WS-AT (there is no onePhase commit) and prepare must add the Xid to the map.
|
void |
debug(String msg) |
String |
getBQualFromWebServiceContextHeaderList(WebServiceContext context)
Called by Coordinator to get/create Xid
|
String |
getCoordinatorAddress() |
Map<WSATXAResource,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>> |
getDurableParticipantPortMap() |
static WSATHelper |
getInstance() |
static WSATHelper |
getInstance(Transactional.Version version) |
String |
getParticipantAddress() |
String |
getRegistrationCoordinatorAddress() |
String |
getRegistrationRequesterAddress() |
String |
getRoutingAddress() |
static TransactionServices |
getTransactionServices()
Return the TransactionServices
See interface for details...
|
Map<Xid,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>> |
getVolatileParticipantPortMap() |
Map<Xid,WSATSynchronization> |
getVolatileParticipantSynchronizationMap() |
int |
getWaitForReplyTimeout()
Amount of time to wait for a reply from a prepare, rollback, commit, or beforeCompletion call before throwing
the appropriate exception, errorcode, etc.
|
String |
getWSATTidFromWebServiceContextHeaderList(WebServiceContext context)
Used by getXidFromWebServiceContextHeaderList in WSATHelper and replayOperation of Coordinator service
|
WLXid |
getXidFromWebServiceContextHeaderList(WebServiceContext context)
Given a WebServiceContext extract and return the WLS WS-AT transaction id and return the translated WLSXid
|
static boolean |
isDebugEnabled()
Need to check if debug is enabled before all logging to prevent unnecessary object creation.
|
void |
prepare(EndpointReference epr,
Xid xid,
WSATXAResource wsatXAResource)
Get/create participant port and place it in the cache, issue prepare upon it, and place the WSATXAResource in the map.
|
void |
rollback(EndpointReference epr,
Xid xid,
WSATXAResource wsatXAResource)
Rollback can be called before or after prepare so we could do a state check here to avoid the
redundant put in the latter case, but it is harmless to re-put and likely not a drastic performance concern.
|
boolean |
setDurableParticipantStatus(Xid xid,
String status)
Called by Coordinator in order to update status and unblock async/one-way calls made for durable participants
|
public static final WSATHelper V10
public static final WSATHelper V11
public static WSATHelper getInstance()
public static WSATHelper getInstance(Transactional.Version version)
public static TransactionServices getTransactionServices()
public int getWaitForReplyTimeout()
public boolean setDurableParticipantStatus(Xid xid, String status)
xid
- XIdstatus
- Stringpublic void prepare(EndpointReference epr, Xid xid, WSATXAResource wsatXAResource) throws XAException
epr
- EndpointReference participant endpoint referencexid
- Xid of transaction as obtained from WSATXAResourcewsatXAResource
- WSATXAResourceXAException
- xaExceptionpublic void commit(EndpointReference epr, Xid xid, WSATXAResource wsatXAResource) throws XAException
epr
- EndpointReference participant endpoint referencexid
- Xid of transaction as obtained from WSATXAResourcewsatXAResource
- WSATXAResourceXAException
- xaExceptionpublic void rollback(EndpointReference epr, Xid xid, WSATXAResource wsatXAResource) throws XAException
epr
- EndpointReference participant endpoint referencexid
- Xid of transaction as obtained from WSATXAResourcewsatXAResource
- WSATXAResourceXAException
- xaExceptionpublic void beforeCompletion(EndpointReference epr, Xid xid, WSATSynchronization wsatSynchronization) throws SOAPException
epr
- EndpointReference participant endpoint referencexid
- Xid of transactionwsatSynchronization
- WSATSynchronizationSOAPException
- soapExceptionpublic String getRoutingAddress()
public String getRegistrationCoordinatorAddress()
public String getCoordinatorAddress()
public String getParticipantAddress()
public String getRegistrationRequesterAddress()
public WLXid getXidFromWebServiceContextHeaderList(WebServiceContext context)
context
- WebServiceContextpublic String getWSATTidFromWebServiceContextHeaderList(WebServiceContext context)
context
- WebServiceContextpublic String getBQualFromWebServiceContextHeaderList(WebServiceContext context)
context
- WebServiceContextpublic static boolean isDebugEnabled()
public Map<WSATXAResource,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>> getDurableParticipantPortMap()
public Map<Xid,WSATSynchronization> getVolatileParticipantSynchronizationMap()
public Map<Xid,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>> getVolatileParticipantPortMap()
public void debug(String msg)
public static String assignUUID()