Package com.ibm.fhir.persistence.proxy.rm

Class RMXAConnectionResource

java.lang.Object

com.ibm.fhir.persistence.proxy.rm.RMXAConnectionResource

All Implemented Interfaces:

PooledConnection, XAConnection, XAResource

public class RMXAConnectionResource
extends Object
implements XAConnection, XAResource

This class is used during XA recovery operations to represent an XAConnection and its associated XAResource, but in reality it serves as a proxy for ALL of the XAConnections and their associated XAResources related to XADataSources cached by the proxy datasource.
This class is only used during the XA Resource recovery operations triggered by the Liberty Recovery Manager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RMXAConnectionResource.XidKey	This inner class is used to represent an xid-based key suitable for use within a HashMap.

Field Summary

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	Description
RMXAConnectionResource(FHIRProxyXADataSource parentDS)	This ctor is invoked by the FHIRProxyXADataSource class when the Liberty Recovery Manager has triggered XA recovery operations.

Method Summary

Modifier and Type	Method	Description
void	addConnectionEventListener(ConnectionEventListener listener)
void	addStatementEventListener(StatementEventListener listener)
static String	bytesToHex(byte[] bytes)	Converts the specified byte array into a string by converting each byte into a 2-digit hex string.
void	close()
void	commit(Xid xid, boolean onePhase)
void	end(Xid xid, int flag)
void	forget(Xid xid)
Connection	getConnection()
List<XAConnection>	getProxiedXAConnections()
Map<String,FHIRProxyXADataSource.DataSourceCacheEntry>	getProxiedXADataSources()
List<XAResource>	getProxiedXAResources()
Map<RMXAConnectionResource.XidKey,List<XAResource>>	getProxiedXids()
int	getTransactionTimeout()
XAResource	getXAResource()
boolean	isSameRM(XAResource otherResource)
int	prepare(Xid xid)
Xid[]	recover(int flag)
void	removeConnectionEventListener(ConnectionEventListener listener)
void	removeStatementEventListener(StatementEventListener listener)
void	rollback(Xid xid)
static void	setBypassFailures(Boolean flag)
void	setProxiedXAConnections(List<XAConnection> proxiedXAConnections)
void	setProxiedXADataSources(Map<String,FHIRProxyXADataSource.DataSourceCacheEntry> proxiedXADataSources)
void	setProxiedXAResources(List<XAResource> proxiedXAResources)
void	setProxiedXids(Map<RMXAConnectionResource.XidKey,List<XAResource>> proxiedXids)
boolean	setTransactionTimeout(int timeoutSecs)
static boolean	shouldBypassFailures()
void	start(Xid xid, int flag)

Methods inherited from class java.lang.Object

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

Constructor Detail

RMXAConnectionResource

public RMXAConnectionResource(FHIRProxyXADataSource parentDS)
                       throws SQLException

This ctor is invoked by the FHIRProxyXADataSource class when the Liberty Recovery Manager has triggered XA recovery operations.

Parameters:

parentDS - the parent FHIRProxyXADataSource instance

Throws:

SQLException

Method Detail

shouldBypassFailures

public static boolean shouldBypassFailures()

setBypassFailures

public static void setBypassFailures(Boolean flag)

getProxiedXADataSources

public Map<String,FHIRProxyXADataSource.DataSourceCacheEntry> getProxiedXADataSources()

setProxiedXADataSources

public void setProxiedXADataSources(Map<String,FHIRProxyXADataSource.DataSourceCacheEntry> proxiedXADataSources)

getProxiedXAConnections

public List<XAConnection> getProxiedXAConnections()

setProxiedXAConnections

public void setProxiedXAConnections(List<XAConnection> proxiedXAConnections)

getProxiedXAResources

public List<XAResource> getProxiedXAResources()

setProxiedXAResources

public void setProxiedXAResources(List<XAResource> proxiedXAResources)

getProxiedXids

public Map<RMXAConnectionResource.XidKey,List<XAResource>> getProxiedXids()

setProxiedXids

public void setProxiedXids(Map<RMXAConnectionResource.XidKey,List<XAResource>> proxiedXids)

getXAResource

public XAResource getXAResource()
                         throws SQLException

Specified by:

getXAResource in interface XAConnection

Throws:

SQLException

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface PooledConnection

Throws:

SQLException

close

public void close()
           throws SQLException

Specified by:

close in interface PooledConnection

Throws:

SQLException

addConnectionEventListener

public void addConnectionEventListener(ConnectionEventListener listener)

Specified by:

addConnectionEventListener in interface PooledConnection

removeConnectionEventListener

public void removeConnectionEventListener(ConnectionEventListener listener)

Specified by:

removeConnectionEventListener in interface PooledConnection

addStatementEventListener

public void addStatementEventListener(StatementEventListener listener)

Specified by:

addStatementEventListener in interface PooledConnection

removeStatementEventListener

public void removeStatementEventListener(StatementEventListener listener)

Specified by:

removeStatementEventListener in interface PooledConnection

recover

public Xid[] recover(int flag)
              throws XAException

Specified by:

recover in interface XAResource

Throws:

XAException

commit

public void commit(Xid xid,
                   boolean onePhase)
            throws XAException

Specified by:

commit in interface XAResource

Throws:

XAException

end

public void end(Xid xid,
                int flag)
         throws XAException

Specified by:

end in interface XAResource

Throws:

XAException

forget

public void forget(Xid xid)
            throws XAException

Specified by:

forget in interface XAResource

Throws:

XAException

getTransactionTimeout

public int getTransactionTimeout()
                          throws XAException

Specified by:

getTransactionTimeout in interface XAResource

Throws:

XAException

isSameRM

public boolean isSameRM(XAResource otherResource)
                 throws XAException

Specified by:

isSameRM in interface XAResource

Throws:

XAException

prepare

public int prepare(Xid xid)
            throws XAException

Specified by:

prepare in interface XAResource

Throws:

XAException

rollback

public void rollback(Xid xid)
              throws XAException

Specified by:

rollback in interface XAResource

Throws:

XAException

setTransactionTimeout

public boolean setTransactionTimeout(int timeoutSecs)
                              throws XAException

Specified by:

setTransactionTimeout in interface XAResource

Throws:

XAException

start

public void start(Xid xid,
                  int flag)
           throws XAException

Specified by:

start in interface XAResource

Throws:

XAException

bytesToHex

public static String bytesToHex(byte[] bytes)

Converts the specified byte array into a string by converting each byte into a 2-digit hex string.

Parameters:

bytes - the byte array to be converted