import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public JmsPooledConnection createPooledConnection(Object xaFactory, ResourceBean bean) throws Exception {
    if (!(xaFactory instanceof XAConnectionFactory))
        throw new IllegalArgumentException("class '" + xaFactory.getClass().getName() + "' does not implement " + XAConnectionFactory.class.getName());
    XAConnectionFactory xaConnectionFactory = (XAConnectionFactory) xaFactory;

    XAConnection xaConnection;
    if (user == null || password == null) {
        if (log.isDebugEnabled()) { log.debug("creating new JMS XAConnection with no credentials"); }
        xaConnection = xaConnectionFactory.createXAConnection();
    }
    else {
        if (log.isDebugEnabled()) { log.debug("creating new JMS XAConnection with user <" + user + "> and password <" + password + ">"); }
        xaConnection = xaConnectionFactory.createXAConnection(user, password);
    }

    JmsPooledConnection jmsPooledConnection = new JmsPooledConnection(this, xaConnection);
    xaStatefulHolders.add(jmsPooledConnection);
    return jmsPooledConnection;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
private XAResourceProducer createMockProducer(String uniqueName) throws RecoveryException {
    XAResourceProducer producer;
    producer = mock(XAResourceProducer.class);
    when(producer.getUniqueName()).thenReturn(uniqueName);

    ResourceBean resourceBean = mock(ResourceBean.class);
    when(resourceBean.getUniqueName()).thenReturn(uniqueName);

    XAResourceHolder resourceHolder = mock(XAResourceHolder.class);
    when(resourceHolder.getResourceBean()).thenReturn(resourceBean);

    XAResource xaResource = mock(XAResource.class);
    when(resourceHolder.getXAResource()).thenReturn(xaResource);

    when(producer.startRecovery()).thenReturn(new XAResourceHolderState(resourceHolder, resourceBean));
    return producer;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public XAStatefulHolder createPooledConnection(Object xaFactory, ResourceBean bean)
		throws Exception {
	if (xaFactory instanceof DirectXADataSource) {
		xaFactory = ((DirectXADataSource) xaFactory).getDataSource();
	}
	return super.createPooledConnection(xaFactory, bean);
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public XAStatefulHolder createPooledConnection(Object xaFactory, ResourceBean bean)
		throws Exception {
	if (xaFactory instanceof DirectXAConnectionFactory) {
		xaFactory = ((DirectXAConnectionFactory) xaFactory).getConnectionFactory();
	}
	return super.createPooledConnection(xaFactory, bean);
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public JdbcPooledConnection createPooledConnection(Object xaFactory, ResourceBean bean) throws Exception {
    if (!(xaFactory instanceof XADataSource))
        throw new IllegalArgumentException("class '" + xaFactory.getClass().getName() + "' does not implement " + XADataSource.class.getName());
    XADataSource xads = (XADataSource) xaFactory;
    JdbcPooledConnection pooledConnection = new JdbcPooledConnection(this, xads.getXAConnection());
    xaResourceHolderMap.put(pooledConnection.getXAResource(), pooledConnection);
    return pooledConnection;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
public XAResourceHolderState(XAResourceHolder resourceHolder, ResourceBean bean) {
    this.bean = bean;
    this.xaResourceHolder = resourceHolder;

    started = false;
    ended = false;
    suspended = false;
    isTimeoutAlreadySet = false;
    xid = null;
    hashCode = 17 * bean.hashCode();
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public MicroserviceResourceHolder createPooledConnection(Object xaFactory, ResourceBean bean) throws Exception {
    throw new UnsupportedOperationException();
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
    * {@inheritDoc}
    */
   @Override
public ResourceBean getResourceBean() {
       return bean;
   }
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public XAStatefulHolder createPooledConnection(Object xaFactory, ResourceBean bean) {
  throw new UnsupportedOperationException("Ehcache is not connection-oriented");
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public ResourceBean getResourceBean() {
  return bean;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public ResourceBean getResourceBean() {
    return getPoolingDataSource();
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public EhCacheXAResourceHolder createPooledConnection(Object xaFactory, ResourceBean bean) throws Exception {
    throw new UnsupportedOperationException("Ehcache is not connection-oriented");
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public ResourceBean getResourceBean() {
    return bean;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
@Override
public ResourceBean getResourceBean() {
    return getPoolingConnectionFactory();
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * Create a new MicroserviceResourceHolder for a particular XAResource
 * 
 * @param resource
 *            the required XAResource
 * @param bean
 *            the required ResourceBean
 */
MicroserviceResourceHolder(XAResource resource, ResourceBean bean) {
    this.resource = resource;
    this.bean = bean;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * Create a new EhCacheXAResourceHolder for a particular XAResource
 * @param resource the required XAResource
 * @param bean the required ResourceBean
 */
Ehcache3XAResourceHolder(XAResource resource, ResourceBean bean) {
  this.resource = resource;
  this.bean = bean;
}
 

import bitronix.tm.resource.common.ResourceBean; //导入依赖的package包/类
/**
 * Create a new EhCacheXAResourceHolder for a particular XAResource
 * @param resource the required XAResource
 * @param bean the required ResourceBean
 */
public EhCacheXAResourceHolder(XAResource resource, ResourceBean bean) {
    this.resource = resource;
    this.bean = bean;
}