import org.objectweb.jotm.Jotm; //导入依赖的package包/类
@Activate
void activate() throws Throwable {
	try {
		RmiConfiguration rmc = new RmiConfiguration() {

			@Override
			public boolean isCorbaCompliant() {
				return false;
			}

			@Override
			public void init() throws RmiConfigurationException {
			}
		};
		jotm = new org.objectweb.jotm.Jotm(true, false, rmc);
		delegate = jotm.getTransactionManager();
	} catch (Throwable t) {
		t.printStackTrace();
		throw t;
	}
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
public JotmFactoryBean() throws NamingException {
	// Check for already active JOTM instance.
	this.jotmCurrent = Current.getCurrent();

	// If none found, create new local JOTM instance.
	if (this.jotmCurrent == null) {
		// Only for use within the current Spring context:
		// local, not bound to registry.
		this.jotm = new Jotm(true, false);
		this.jotmCurrent = Current.getCurrent();
	}
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
/**
 * Constructor for DatabaseResource.
 */
public DatabaseResource(final String name) throws SyncDatabaseException,
		IOException, NamingException, SQLException {
	if (name == null) {
		throw new SyncDatabaseException("error.argument");
	}

	final JdbcResource jdbcResource = JdbcResource.getJdbcResource(
			RESOURCE_FILE_NAME, name);
	if (jdbcResource == null) {
		throw new SyncDatabaseException("error.resource_notfound", name);
	}

	isOracle = jdbcResource.getUrl().contains("jdbc:oracle:");

	log.debug(jdbcResource.getName() + " configuration:"
			+ jdbcResource.getUsername() + "/" + jdbcResource.getUrl()
			+ "/" + jdbcResource.getClassName());

	/*
	 * Get a transaction manager. creates an instance of JOTM with a local
	 * transaction factory. which is not bound to a registry.
	 */
	try {
		jotm = new Jotm(true, false);

		xads = new StandardXADataSource();
		((StandardXADataSource) xads).setDriverName(jdbcResource
				.getClassName());
		((StandardXADataSource) xads).setUrl(jdbcResource.getUrl());
		((StandardXADataSource) xads).setTransactionManager(jotm
				.getTransactionManager());

		xaconn = xads.getXAConnection(jdbcResource.getUsername(),
				jdbcResource.getPassword());
	} catch (final Exception e) {
		if (jotm != null) {
			jotm.stop();
		}

		throw new SyncDatabaseException("error.message", e.getMessage());
	}
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected void beforeTestsStarted() throws Exception {
    jotm = new Jotm(true, false);

    super.beforeTestsStarted();
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
/**
 * Sole constructor.
 */
public JotmTransactionManagerFactory() throws NamingException
{
  tmService = new Jotm(true,    // create as a local transaction factory
                       false);  // not bound in an RMI or CORBA registry
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
public void setup() throws Exception {
  logger.info("Doing setup");
  sessionFactory = SessionFactoryFinder.newSessionFactory(databaseURI);
  txService = new Jotm(true, false); // local, unbound.
  txManager = txService.getTransactionManager();
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected void beforeTestsStarted() throws Exception {
    super.beforeTestsStarted();

    jotm = new Jotm(true, false);

    Current.setAppServer(false);

    startGrid();
}
 

import org.objectweb.jotm.Jotm; //导入依赖的package包/类
/**
 * Return the JOTM instance created by this factory bean, if any.
 * Will be <code>null</code> if an already active JOTM instance is used.
 * <p>Application code should never need to access this.
 */
public Jotm getJotm() {
	return this.jotm;
}