问Atomikos事务管理spring boot/spring jams

EN

public class CusListener implements MessageListener{
public void onMessage(Message message) {

    //Database call

    catch (Exception ex) {

                throw (new RuntimeException());
                }

}
}



@Configuration
public class ListenerContainer{

    @Bean
    public  DefaultMessageListenerContainer  defaultMessageListenerContainer(ConnectionFactory queueConnectionFactory,MQQueue queue, MessageListener listener,
            JtaTransactionManager jtaTransactionManager) {


        DefaultMessageListenerContainer defaultMessageListenerContainer =
                new DefaultMessageListenerContainer();
        defaultMessageListenerContainer.setConnectionFactory(queueConnectionFactory);               
        defaultMessageListenerContainer.setDestination(queue);
        defaultMessageListenerContainer.setMessageListener(listerner);
        defaultMessageListenerContainer.setTransactionManager(jtaTransactionManager);
        defaultMessageListenerContainer.setSessionTransacted(true);
        defaultMessageListenerContainer.setConcurrency("3-10");


        return defaultMessageListenerContainer; 
}

    //other beans declaration passed in the method above
}



@Configuration
public class PlanListenerSqlSessFac {


    @Bean(name="sqlSessionFactory")
    public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSource") NMCryptoDataSourceWrapper dataSource) throws Exception {

    }



    @Bean(name="driverManagerDataSource")
    public DriverManagerDataSource driverManagerDataSource() {
        DriverManagerDataSource driverManagerDataSource = new DriverManagerDataSource();

        return driverManagerDataSource;
       }