SimpleTaskConfiguration в облачной задаче Spring и SimpleBatchConfiguration в весеннем пакете, предотвращающие автоматическую настройку весенней загрузки транзакций XA

У меня была та же проблема, и мое решение состояло в том, чтобы реализовать BatchConfigurer (сохранив @EnableBatchProcessing) и вручную добавить bean-компоненты atomikos.

Конфигурация работы:

@Configuration
@EnableBatchProcessing
public class JobConfig implements BatchConfigurer {

    @Autowired
    private DataSource dataSource;

    @Autowired
    private JtaTransactionManager jtaTransactionManager;

    // ... skipping some code 

    @Override
    public JobRepository getJobRepository() throws Exception {
        JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
        factory.setDataSource(dataSource);
        factory.setTransactionManager(jtaTransactionManager);
        return factory.getObject();
    }

    @Override
    public PlatformTransactionManager getTransactionManager() throws Exception {
        return jtaTransactionManager;
    }

    @Override
    public JobLauncher getJobLauncher() throws Exception {
        SimpleJobLauncher launcher = new SimpleJobLauncher();
        launcher.setJobRepository(getJobRepository());
        launcher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        return launcher;
    }

    @Override
    public JobExplorer getJobExplorer() throws Exception {
        JobExplorerFactoryBean jobExplorerFactoryBean = new JobExplorerFactoryBean();
        jobExplorerFactoryBean.setDataSource(dataSource);
        jobExplorerFactoryBean.afterPropertiesSet();
        return jobExplorerFactoryBean.getObject();
    } 

АтомикосКонфигурация:

@Configuration
public class AtomikosConfig extends AbstractJtaPlatform {

    @Bean(initMethod = "init", destroyMethod = "close")
    @DependsOn("atomikosUserTransactionService")
    public UserTransactionManager atomikosTransactionManager() {
            UserTransactionManager manager = new UserTransactionManager();
            manager.setForceShutdown(false);
            manager.setStartupTransactionService(false);
            return manager;
    }

    @Bean(initMethod = "init", destroyMethod = "shutdownForce")
    public UserTransactionServiceImp atomikosUserTransactionService() {
            Properties properties = new Properties();
            return new UserTransactionServiceImp(properties);
    }

    @Bean
    public UserTransactionImp atomikosUserTransaction() throws SystemException {
            UserTransactionImp transaction = new UserTransactionImp();
            transaction.setTransactionTimeout(300);
            return transaction;
    }

    @Primary
    @Bean
    public JtaTransactionManager jtaTransactionManager() throws Exception {
            JtaTransactionManager manager = new JtaTransactionManager();
            manager.setTransactionManager(atomikosTransactionManager());
            manager.setUserTransaction(atomikosUserTransaction());
            manager.setAllowCustomIsolationLevels(true);
            return manager;
    }

    @Bean
    public ActiveMQXAConnectionFactory xaFactory() {
            ActiveMQXAConnectionFactory factory = new ActiveMQXAConnectionFactory();
            factory.setBrokerURL("tcp://localhost:61616");
            factory.setUserName("admin");
            factory.setPassword("admin");
            //factory.setTrustAllPackages(true);
            factory.setTransactedIndividualAck(true);
            return factory;
    }

    @Bean(initMethod = "init", destroyMethod = "close")
    public AtomikosConnectionFactoryBean connectionFactory() {
            AtomikosConnectionFactoryBean factoryBean = new AtomikosConnectionFactoryBean();
            factoryBean.setUniqueResourceName("amq1");
            factoryBean.setXaConnectionFactory(xaFactory());
            factoryBean.setMaxPoolSize(10);
            return factoryBean;
    }

    @Bean
    public AtomikosJtaPlatform springJtaPlatformAdapter() throws Exception {
            AtomikosJtaPlatform platform = new AtomikosJtaPlatform();
            platform.setJtaTransactionManager(jtaTransactionManager());
            platform.setTransactionManager(atomikosTransactionManager());
            platform.setUserTransaction(atomikosUserTransaction());
            return platform;
    }

    @Override
    protected TransactionManager locateTransactionManager() {
            return atomikosTransactionManager();
    }

    @Override
    protected UserTransaction locateUserTransaction() {
            return atomikosTransactionManager();
    }

Посмотрев на ваш пример, я могу сказать вам следующее: нет никакого способа заставить автоконфигурацию работать, даже если вы отключите автоконфигурацию для управления транзакциями, что вы пытались, автоконфигурации задач и пакетов (запущенные @EnableBatchProcessing и @EnableTask) по-прежнему будут регистрировать свои собственные менеджеры транзакций и, таким образом, предотвращать запуск Atomikos Configuration. Причина этого в том, что @EnableBatchProcessing включает в себя класс конфигурации BatchConfigurationSelector, который, в свою очередь, включает либо SimpleBatchConfiguration, либо ModularBatchConfiguration, и оба они всегда будут регистрировать диспетчер транзакций - ни в одном из определений bean-компонентов нет условных аннотаций. @EnableTask делает то же самое, только с SimpleTaskConfiguration.

Таким образом, единственный выход из этого, который я вижу, — это полностью вручную создавать конфигурации пакетов и задач.

Что касается того, как вручную настроить пакет и задачи, я бы рекомендовал посмотреть SimpleTaskConfiguration и AbstractBatchConfiguration — вы можете увидеть там все бобы, которые вам нужно зарегистрировать.

Кроме того, вы можете увидеть пакетный пример на этой странице Java Code Geeks. вам следует просто преобразовать конфигурацию XML в конфигурацию Java.