Package weblogic.wsee.wstx.wsat

Class WSATHelper<T>

java.lang.Object

weblogic.wsee.wstx.wsat.WSATHelper<T>

public class WSATHelper<T>
extends java.lang.Object

This singleton serves not only as a helper and utility but as the core of the WS-AT resource manager and holds the datastructures that maintain the endpoint references for durable/XAResource and volatile/Synchronization WS-AT transaction participants. Rather than translate back and forth between the WLS WS-AT and internal Xid, the WLS WS-AT could simply be used for the keys in this class, however, we are working with Xids as keys and identity for convenience and better debug logging information as there do not appear to be any substantial performance implications.

Field Summary

Fields

Modifier and Type	Field	Description
static WSATHelper	V10
static WSATHelper	V11

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WSATHelper()

Method Summary

Modifier and Type	Method	Description
static java.lang.String	assignUUID()
void	beforeCompletion(javax.xml.ws.EndpointReference epr, javax.transaction.xa.Xid xid, WSATSynchronization wsatSynchronization)	beforeCompletion call on volatile participant
void	commit(javax.xml.ws.EndpointReference epr, javax.transaction.xa.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(java.lang.String msg)
java.lang.String	getBQualFromWebServiceContextHeaderList(javax.xml.ws.WebServiceContext context)	Called by Coordinator to get/create Xid
java.lang.String	getCoordinatorAddress()
java.util.Map<WSATXAResource,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>>	getDurableParticipantPortMap()
static WSATHelper	getInstance()
static WSATHelper	getInstance(weblogic.wsee.wstx.wsat.Transactional.Version version)
java.lang.String	getParticipantAddress()
java.lang.String	getRegistrationCoordinatorAddress()
java.lang.String	getRegistrationRequesterAddress()
java.lang.String	getRoutingAddress()
static TransactionServices	getTransactionServices()	Return the TransactionServices See interface for details...
java.util.Map<javax.transaction.xa.Xid,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>>	getVolatileParticipantPortMap()
java.util.Map<javax.transaction.xa.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.
java.lang.String	getWSATTidFromWebServiceContextHeaderList(javax.xml.ws.WebServiceContext context)	Used by getXidFromWebServiceContextHeaderList in WSATHelper and replayOperation of Coordinator service
WLXid	getXidFromWebServiceContextHeaderList(javax.xml.ws.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(javax.xml.ws.EndpointReference epr, javax.transaction.xa.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(javax.xml.ws.EndpointReference epr, javax.transaction.xa.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(javax.transaction.xa.Xid xid, java.lang.String status)	Called by Coordinator in order to update status and unblock async/one-way calls made for durable participants

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

V10

public static final WSATHelper V10

V11

public static final WSATHelper V11

Constructor Detail

WSATHelper

protected WSATHelper()

Method Detail

getInstance

public static WSATHelper getInstance()

getInstance

public static WSATHelper getInstance(weblogic.wsee.wstx.wsat.Transactional.Version version)

getTransactionServices

public static TransactionServices getTransactionServices()

Return the TransactionServices See interface for details...

Returns:

TransactionServices which interfaces WS-AT with underlying transaction processing system

getWaitForReplyTimeout

public 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.

Returns:

time in milliseconds

setDurableParticipantStatus

public boolean setDurableParticipantStatus(javax.transaction.xa.Xid xid,
                                           java.lang.String status)

Called by Coordinator in order to update status and unblock async/one-way calls made for durable participants

Parameters:

xid - XId

status - String

Returns:

boolean true if the status was set successfully

prepare

public void prepare(javax.xml.ws.EndpointReference epr,
                    javax.transaction.xa.Xid xid,
                    WSATXAResource wsatXAResource)
             throws javax.transaction.xa.XAException

Get/create participant port and place it in the cache, issue prepare upon it, and place the WSATXAResource in the map.

Parameters:

epr - EndpointReference participant endpoint reference

xid - Xid of transaction as obtained from WSATXAResource

wsatXAResource - WSATXAResource

Throws:

javax.transaction.xa.XAException - xaException

commit

public void commit(javax.xml.ws.EndpointReference epr,
                   javax.transaction.xa.Xid xid,
                   WSATXAResource wsatXAResource)
            throws javax.transaction.xa.XAException

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.

Parameters:

epr - EndpointReference participant endpoint reference

xid - Xid of transaction as obtained from WSATXAResource

wsatXAResource - WSATXAResource

Throws:

javax.transaction.xa.XAException - xaException

rollback

public void rollback(javax.xml.ws.EndpointReference epr,
                     javax.transaction.xa.Xid xid,
                     WSATXAResource wsatXAResource)
              throws javax.transaction.xa.XAException

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.

Parameters:

epr - EndpointReference participant endpoint reference

xid - Xid of transaction as obtained from WSATXAResource

wsatXAResource - WSATXAResource

Throws:

javax.transaction.xa.XAException - xaException

beforeCompletion

public void beforeCompletion(javax.xml.ws.EndpointReference epr,
                             javax.transaction.xa.Xid xid,
                             WSATSynchronization wsatSynchronization)
                      throws javax.xml.soap.SOAPException

beforeCompletion call on volatile participant

Parameters:

epr - EndpointReference participant endpoint reference

xid - Xid of transaction

wsatSynchronization - WSATSynchronization

Throws:

javax.xml.soap.SOAPException - soapException

getRoutingAddress

public java.lang.String getRoutingAddress()

getRegistrationCoordinatorAddress

public java.lang.String getRegistrationCoordinatorAddress()

getCoordinatorAddress

public java.lang.String getCoordinatorAddress()

getParticipantAddress

public java.lang.String getParticipantAddress()

getRegistrationRequesterAddress

public java.lang.String getRegistrationRequesterAddress()

getXidFromWebServiceContextHeaderList

public WLXid getXidFromWebServiceContextHeaderList(javax.xml.ws.WebServiceContext context)

Given a WebServiceContext extract and return the WLS WS-AT transaction id and return the translated WLSXid

Parameters:

context - WebServiceContext

Returns:

WLXid found in WebServiceContext or fault

getWSATTidFromWebServiceContextHeaderList

public java.lang.String getWSATTidFromWebServiceContextHeaderList(javax.xml.ws.WebServiceContext context)

Used by getXidFromWebServiceContextHeaderList in WSATHelper and replayOperation of Coordinator service

Parameters:

context - WebServiceContext

Returns:

WS-AT Txid String

getBQualFromWebServiceContextHeaderList

public java.lang.String getBQualFromWebServiceContextHeaderList(javax.xml.ws.WebServiceContext context)

Called by Coordinator to get/create Xid

Parameters:

context - WebServiceContext

Returns:

String bqual

isDebugEnabled

public static boolean isDebugEnabled()

Need to check if debug is enabled before all logging to prevent unnecessary object creation.

Returns:

true if debug for the WS-AT logger is enabled, false otherwise

getDurableParticipantPortMap

public java.util.Map<WSATXAResource,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>> getDurableParticipantPortMap()

getVolatileParticipantSynchronizationMap

public java.util.Map<javax.transaction.xa.Xid,WSATSynchronization> getVolatileParticipantSynchronizationMap()

getVolatileParticipantPortMap

public java.util.Map<javax.transaction.xa.Xid,weblogic.wsee.wstx.wsat.common.ParticipantIF<T>> getVolatileParticipantPortMap()

debug

public void debug(java.lang.String msg)

assignUUID

public static java.lang.String assignUUID()