weblogic.wsee.wstx.wsat

Class WSATXAResource

java.lang.Object

weblogic.wsee.wstx.wsat.WSATXAResource

All Implemented Interfaces:

java.io.Serializable, javax.transaction.xa.XAResource, WSATConstants

public class WSATXAResource
extends java.lang.Object
implements WSATConstants, javax.transaction.xa.XAResource, java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.lang.String	ACTIVE
private javax.xml.ws.EndpointReference	m_epr
private boolean	m_isRemovedFromMap
private java.lang.String	m_status
private Transactional.Version	m_version
private javax.transaction.xa.Xid	m_xid
(package private) static long	serialVersionUID

Fields inherited from interface weblogic.wsee.wstx.wsat.WSATConstants

ABORTED, ACTION, ADDRESS, BRANCHQUAL, BRANCHQUAL_QNAME, COMMIT, COMMITTED, COORDINATION_CONTEXT, COORDINATION_TYPE, COORDINATOR_PROTOCOL_SERVICE, CURRENT_WSCOOR, DEBUG_WSAT, DURABLE_2PC, EXPIRES, FAULT_TO, FROM, HTTP_SCHEMAS_XMLSOAP_ORG_WS_2004_10_WSAT, HTTP_SCHEMAS_XMLSOAP_ORG_WS_2004_10_WSAT_DURABLE_2PC, HTTP_SCHEMAS_XMLSOAP_ORG_WS_2004_10_WSAT_VOLATILE_2PC, IDENTIFIER, MESSAGE_ID, MUST_UNDERSTAND, PARTICIPANT_PROTOCOL_SERVICE, PREPARE, PREPARED, PROTOCOL_IDENTIFIER, READONLY, REFERENCE_PARAMETERS, REGISTER, REGISTER_RESPONSE, REGISTRATION_SERVICE, REPLAY, REPLY_TO, ROLLBACK, ROUTING, ROUTING_QNAME, SOAP_ENVELOPE, TO, TXID, TXID_QNAME, TXPROP_WSAT_FOREIGN_RECOVERY_CONTEXT, VOLATILE_2PC, WLA_WSAT_NS_URI, WLS_WSAT, WSA, WSADDRESSING_NS_URI, WSAT, WSAT_COORDINATORPORTTYPEPORT, WSAT_PARTICIPANTPORTTYPEPORT, WSAT_REGISTRATIONCOORDINATORPORTTYPEPORT, WSAT_REGISTRATIONREQUESTERPORTTYPEPORT, WSAT10_NS_URI, WSAT11_COORDINATORPORTTYPEPORT, WSAT11_DURABLE_2PC, WSAT11_NS_URI, WSAT11_PARTICIPANTPORTTYPEPORT, WSAT11_REGISTRATIONCOORDINATORPORTTYPEPORT, WSAT11_REGISTRATIONREQUESTERPORTTYPEPORT, WSAT11_VOLATILE_2PC, WSCOOR, WSCOOR_CONTEXT_QNAME, WSCOOR_REGISTER_QNAME, WSCOOR10_NS_URI, WSCOOR11_CONTEXT_QNAME, WSCOOR11_NS_URI, WSCOOR11_REGISTER_QNAME

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Constructor Summary

Constructors

Constructor and Description
WSATXAResource(javax.xml.ws.EndpointReference epr, javax.transaction.xa.Xid xid) Constructor used for runtime
WSATXAResource(Transactional.Version version, javax.xml.ws.EndpointReference epr, javax.transaction.xa.Xid xid) Constructor used for runtime
WSATXAResource(Transactional.Version version, javax.xml.ws.EndpointReference epr, javax.transaction.xa.Xid xid, boolean isRecovery) Constructor used for recovery

Method Summary

Modifier and Type	Method and Description
void	commit(javax.transaction.xa.Xid xid, boolean onePhase) Commit.
void	end(javax.transaction.xa.Xid xid, int i) Not applicable to WS-AT
boolean	equals(java.lang.Object obj) Equality check based on instanceof and Xid that identifies this Synchronization
protected void	finalize() Prevents leaks in the event of protocol exceptions, abandonments, etc.
void	forget(javax.transaction.xa.Xid xid) Not applicable to WS-AT
int	getTransactionTimeout() Not applicable to WS-AT
(package private) int	getWaitForReplyTimeout() Returns the amount of time to wait for replies to prepare, commit, and rollback calls
(package private) WSATHelper	getWSATHelper()
javax.transaction.xa.Xid	getXid() Returns Xid for use in equality, as key in durable participant map, and from gateway registerWSATResource of subordinate/participant.
int	hashCode()
boolean	isSameRM(javax.transaction.xa.XAResource xaResource) Not applicable to WS-AT
private void	log(java.lang.String message)
private void	logSuccess(java.lang.String method)
private javax.transaction.xa.XAException	newFailedStateXAExceptionForMethodNameAndErrorcode(java.lang.String method, int errorcode)
int	prepare(javax.transaction.xa.Xid xid)
private void	readObject(java.io.ObjectInputStream ois)
javax.transaction.xa.Xid[]	recover(int i) Not applicable to WS-AT
void	rollback(javax.transaction.xa.Xid xid)
void	setBranchQualifier(byte[] bqual) Called from Registration to set branch qualifier that was generated during enlist
void	setStatus(java.lang.String status) Called by Coordinator service in reaction to completion operation call in order to setStatus accordingly
boolean	setTransactionTimeout(int i) Not applicable to WS-AT
void	start(javax.transaction.xa.Xid xid, int i) Not applicable to WS-AT
java.lang.String	toString()
private void	writeObject(java.io.ObjectOutputStream oos)

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

static final long serialVersionUID

See Also:

Constant Field Values

m_xid

private javax.transaction.xa.Xid m_xid

ACTIVE

static final java.lang.String ACTIVE

See Also:

Constant Field Values

m_status

private volatile java.lang.String m_status

m_version

private Transactional.Version m_version

m_isRemovedFromMap

private boolean m_isRemovedFromMap

m_epr

private transient javax.xml.ws.EndpointReference m_epr

Constructor Detail

WSATXAResource

public WSATXAResource(javax.xml.ws.EndpointReference epr,
                      javax.transaction.xa.Xid xid)

Constructor used for runtime

Parameters:

epr - SEndpointReference participant endpoint reference

xid - Xid of transaction

WSATXAResource

public WSATXAResource(Transactional.Version version,
                      javax.xml.ws.EndpointReference epr,
                      javax.transaction.xa.Xid xid)

Constructor used for runtime

Parameters:

version - Transactional.Version

epr - EndpointReference participant endpoint reference

xid - Xid of transaction

WSATXAResource

public WSATXAResource(Transactional.Version version,
                      javax.xml.ws.EndpointReference epr,
                      javax.transaction.xa.Xid xid,
                      boolean isRecovery)

Constructor used for recovery

Parameters:

version - Transactional.Version

epr - EndpointReference participant endpoint reference

xid - Xid of transaction

isRecovery - true if for recovery, false if not (ie if for runtime)

Method Detail

getWSATHelper

WSATHelper getWSATHelper()

setStatus

public void setStatus(java.lang.String status)

Called by Coordinator service in reaction to completion operation call in order to setStatus accordingly

Parameters:

status - String status as found in WSATConstants.

prepare

public int prepare(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

Specified by:

prepare in interface javax.transaction.xa.XAResource

Parameters:

xid - Xid The actual Xid passed in is ignored and the member variable used instead as the value passed in as there is a final 1-to-1 relationship between WSATXAResource and Xid. In reality is doesn't matter but in order to be consistent with rollback (where it does matter), the member variable is used

Returns:

int prepare vote

Throws:

javax.transaction.xa.XAException - xaException

newFailedStateXAExceptionForMethodNameAndErrorcode

private javax.transaction.xa.XAException newFailedStateXAExceptionForMethodNameAndErrorcode(java.lang.String method,
                                                                                            int errorcode)

finalize

protected void finalize()
                 throws java.lang.Throwable

Prevents leaks in the event of protocol exceptions, abandonments, etc. This has the requirement that transactions are never recreated for recovery from scratch using in-memory records

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable - he Exception raised by this method

commit

public void commit(javax.transaction.xa.Xid xid,
                   boolean onePhase)
            throws javax.transaction.xa.XAException

Commit.

Specified by:

commit in interface javax.transaction.xa.XAResource

Parameters:

xid - Xid The actual Xid passed in is ignored and the member variable used instead as there is a final 1-to-1 relationship between WSATXAResource and Xid during construction. In reality is doesn't matter but in order to be consistent with rollback (where it does matter), the member variable is used

onePhase - there is no single phase commit in WS-AT and so this is ignored

Throws:

javax.transaction.xa.XAException - xaException

getWaitForReplyTimeout

int getWaitForReplyTimeout()

Returns the amount of time to wait for replies to prepare, commit, and rollback calls

Returns:

wait time in milliseconds

rollback

public void rollback(javax.transaction.xa.Xid xid)
              throws javax.transaction.xa.XAException

Specified by:

rollback in interface javax.transaction.xa.XAResource

Parameters:

xid - Xid The actual Xid passed in is ignored and the member variable used instead as the value passed in will be null for bottom-up recovery and because there is a final 1-to-1 relationship between WSATXAResource and Xid.

Throws:

javax.transaction.xa.XAException

forget

public void forget(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

forget in interface javax.transaction.xa.XAResource

Parameters:

xid - Xid

Throws:

javax.transaction.xa.XAException

setTransactionTimeout

public boolean setTransactionTimeout(int i)
                              throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

setTransactionTimeout in interface javax.transaction.xa.XAResource

Parameters:

i - timeout

Returns:

boolean

Throws:

javax.transaction.xa.XAException

start

public void start(javax.transaction.xa.Xid xid,
                  int i)
           throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

start in interface javax.transaction.xa.XAResource

Parameters:

xid - Xid

i - flag

Throws:

javax.transaction.xa.XAException

end

public void end(javax.transaction.xa.Xid xid,
                int i)
         throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

end in interface javax.transaction.xa.XAResource

Parameters:

xid - Xid

i - flag

Throws:

javax.transaction.xa.XAException - xaexception

getTransactionTimeout

public int getTransactionTimeout()
                          throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

getTransactionTimeout in interface javax.transaction.xa.XAResource

Returns:

int timeout

Throws:

javax.transaction.xa.XAException

isSameRM

public boolean isSameRM(javax.transaction.xa.XAResource xaResource)
                 throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

isSameRM in interface javax.transaction.xa.XAResource

Parameters:

xaResource - XAResource

Returns:

boolean must be false

Throws:

javax.transaction.xa.XAException - xaexeception

recover

public javax.transaction.xa.Xid[] recover(int i)
                                   throws javax.transaction.xa.XAException

Not applicable to WS-AT

Specified by:

recover in interface javax.transaction.xa.XAResource

Parameters:

i - flag

Returns:

empty array

Throws:

javax.transaction.xa.XAException - xaexception

getXid

public javax.transaction.xa.Xid getXid()

Returns Xid for use in equality, as key in durable participant map, and from gateway registerWSATResource of subordinate/participant.

Returns:

Xid that identifies this XAResource

setBranchQualifier

public void setBranchQualifier(byte[] bqual)

Called from Registration to set branch qualifier that was generated during enlist

Parameters:

bqual - byte[]

equals

public boolean equals(java.lang.Object obj)

Equality check based on instanceof and Xid that identifies this Synchronization

Overrides:

equals in class java.lang.Object

Parameters:

obj - Object to conduct equality check against

Returns:

if equal

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

writeObject

private void writeObject(java.io.ObjectOutputStream oos)
                  throws java.io.IOException

Throws:

java.io.IOException

readObject

private void readObject(java.io.ObjectInputStream ois)
                 throws java.lang.ClassNotFoundException,
                        java.io.IOException

Throws:

java.lang.ClassNotFoundException

java.io.IOException

log

private void log(java.lang.String message)

logSuccess

private void logSuccess(java.lang.String method)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object