Spring Boot集成atomikos快速入门Demo
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Primary;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import com.atomikos.icatch.jta.UserTransactionImp;
import com.atomikos.icatch.jta.UserTransactionManager;
import javax.transaction.UserTransaction;
import javax.transaction.SystemException;
import javax.sql.XADataSource;
import com.atomikos.jdbc.AtomikosDataSourceBean;
import com.atomikos.icatch.jta.JTATransactionManager;
@SpringBootApplication
@EnableTransactionManagement
public class Application {
@Bean
public UserTransactionManager atomikosTransactionManager() throws SystemException {
UserTransactionManager userTransactionManager = new UserTransactionManager();
userTransactionManager.setForceShutdown(false);
userTransactionManager.init();
return userTransactionManager;
}
@Bean
@Primary
public PlatformTransactionManager transactionManager() throws SystemException {
JTATransactionManager transactionManager = new JTATransactionManager();
transactionManager.setUserTransaction(atomikosTransactionManager());
transactionManager.setTransactionManager(atomikosTransactionManager());
transactionManager.afterPropertiesSet();
return transactionManager;
}
@Bean
public UserTransaction userTransaction() throws SystemException {
UserTransactionImp userTransactionImp = new UserTransactionImp();
userTransactionImp.setTransactionTimeout(10000);
userTransactionImp.setTransactionManager(atomikosTransactionManager());
userTransactionImp.init();
return userTransactionImp;
}
@Bean
public AtomikosDataSourceBean dataSource1() throws Exception {
AtomikosDataSourceBean ds1 = n
评论已关闭