Я использую springboot , чтобы получить сообщение JMS (от oracle AQ), сделать некоторые вещи, используя atomikos и SpringData JPA.
Работает нормально, кроме случаев истечения времени ожидания транзакции. Все, что сделано с использованием JPA, фиксируется, но сообщение JMS отправляется в очередь исключений.
Мое ожидаемое поведение - откат и сообщений JMS, и операций JPA и остановка с той же ошибкой, которую я в настоящее время получаю. Кроме того, я также хотел понять, как я могу иметь частичную фиксацию внутри (как выглядит) одной открытой транзакции (см. Журнал ниже)?
Код такой простой:
// if this method take more than the transation timeout
// then everything done using JPA in commited but the JMS message goes to the exception QUEUE
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void execute(String... args) {
// Consume message from queue and get the associated object from database using JPA
T object = this.read();
// process this object
this.process(object);
}
Я помещаю все в DEBUG и не вижу ничего релевантного в журнале:
16/04/2020 15:33:33.459 [main] DEBUG com.atomikos.icatch.imp.CompositeTransactionManagerImp - createCompositeTransaction ( 50000 ): created new ROOT transaction with id 50.157.120.30.tm158704401345900002
-- SOMETHING TAKING LONG TIME HERE
16/04/2020 15:34:23.747 [Atomikos:2] WARN com.atomikos.icatch.imp.ActiveStateHandler - Transaction 50.157.120.30.tm158704401345900002 has timed out and will rollback.
-- SOMETHING TAKING LONG TIME HERE
16/04/2020 15:33:33.462 [main] DEBUG com.atomikos.icatch.imp.CompositeTransactionImp - registerSynchronization ( com.atomikos.icatch.jta.Sync2Sync@af0f99a9 ) for transaction 50.157.120.30.tm158704401345900002
16/04/2020 15:35:18.025 [main] DEBUG com.atomikos.icatch.imp.CompositeTransactionImp - commit() done (by application) of transaction 50.157.120.30.tm158704401345900002
Вот моя конфигурация
@Bean
public DataSource dataSource() throws SQLException {
// Also tried with :
// OracleXADataSource dataSource = new OracleXADataSource();
OracleConnectionPoolDataSource dataSource = new OracleConnectionPoolDataSource();
dataSource.setURL(url);
dataSource.setUser(login);
dataSource.setPassword(password);
return dataSource;
}
@Bean
public ConnectionFactory connectionFactory(DataSource datasource) throws JMSException, SQLException {
return AQjmsFactory.getQueueConnectionFactory(datasource);
// Also tried with :
/*
XAQueueConnectionFactory xacf = AQjmsFactory.getXAQueueConnectionFactory(dataSource());
AtomikosConnectionFactoryBean qcf = new AtomikosConnectionFactoryBean();
qcf.setUniqueResourceName("MYDS");
qcf.setXaConnectionFactory(xacf);
return qcf;
*/
}
@Bean
public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) {
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(connectionFactory);
SimpleMessageConverter converter = new SimpleMessageConverter();
jmsTemplate.setMessageConverter(converter);
jmsTemplate.setSessionTransacted(true);
jmsTemplate.setDefaultDestinationName("AQADMIN.MYQUEUE");
return jmsTemplate;
}
И полная трассировка стека
org.springframework.transaction.UnexpectedRollbackException: JTA transaction unexpectedly rolled back (maybe due to a timeout); nested exception is javax.transaction.RollbackException: Rolled back already.
at org.springframework.transaction.jta.JtaTransactionManager.doCommit(JtaTransactionManager.java:1037) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(AbstractPlatformTransactionManager.java:746) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:714) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.transaction.interceptor.TransactionAspectSupport.commitTransactionAfterReturning(TransactionAspectSupport.java:533) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:304) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
at my.package.batch.indicateurs.calcul.BatchCalculerIndicateurs$$EnhancerBySpringCGLIB$$81a5c815.execute(<generated>) ~[classes!/:4.1.0-SNAPSHOT]
at my.package.framework.MyBatchLauncher.execute(MyBatchLauncher.java:99) ~[brm-batch-frameworkspring-4.1.0-SNAPSHOT.jar!/:4.1.0-SNAPSHOT]
at my.package.framework.MyBatchLauncher.runBatch(MyBatchLauncher.java:66) ~[brm-batch-frameworkspring-4.1.0-SNAPSHOT.jar!/:4.1.0-SNAPSHOT]
at my.package.framework.MyBatchLauncher.run(MyBatchLauncher.java:44) ~[brm-batch-frameworkspring-4.1.0-SNAPSHOT.jar!/:4.1.0-SNAPSHOT]
at my.package.framework.MyCommandLineRunner.lambda$commandLineRunner$0(MyCommandLineRunner.java:55) ~[brm-batch-frameworkspring-4.1.0-SNAPSHOT.jar!/:4.1.0-SNAPSHOT]
at my.package.framework.MyCommandLineRunner$$Lambda$525.0000000085F87050.run(Unknown Source) ~[?:?]
at org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:813) [spring-boot-2.1.0.RELEASE.jar!/:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.callRunners(SpringApplication.java:797) [spring-boot-2.1.0.RELEASE.jar!/:2.1.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:324) [spring-boot-2.1.0.RELEASE.jar!/:2.1.0.RELEASE]
at my.package.framework.MyCommandLineRunner.main(MyCommandLineRunner.java:40) [brm-batch-frameworkspring-4.1.0-SNAPSHOT.jar!/:4.1.0-SNAPSHOT]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:95) ~[?:1.8.0]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:55) ~[?:1.8.0]
at java.lang.reflect.Method.invoke(Method.java:508) ~[?:1.8.0]
at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48) [CalculerIndicateurs-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
at org.springframework.boot.loader.Launcher.launch(Launcher.java:87) [CalculerIndicateurs-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
at org.springframework.boot.loader.Launcher.launch(Launcher.java:50) [CalculerIndicateurs-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:51) [CalculerIndicateurs-4.1.0-SNAPSHOT.jar:4.1.0-SNAPSHOT]
Caused by: javax.transaction.RollbackException: Rolled back already.
at com.atomikos.icatch.jta.TransactionImp.rethrowAsJtaRollbackException(TransactionImp.java:48) ~[transactions-jta-4.0.6.jar!/:?]
at com.atomikos.icatch.jta.TransactionImp.commit(TransactionImp.java:188) ~[transactions-jta-4.0.6.jar!/:?]
at com.atomikos.icatch.jta.TransactionManagerImp.commit(TransactionManagerImp.java:414) ~[transactions-jta-4.0.6.jar!/:?]
at com.atomikos.icatch.jta.UserTransactionManager.commit(UserTransactionManager.java:159) ~[transactions-jta-4.0.6.jar!/:?]
at org.springframework.transaction.jta.JtaTransactionManager.doCommit(JtaTransactionManager.java:1034) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
... 25 more
Caused by: com.atomikos.icatch.RollbackException: Rolled back already.
at com.atomikos.icatch.imp.CoordinatorStateHandler.commitFromWithinCallback(CoordinatorStateHandler.java:393) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.imp.ActiveStateHandler$6.doCommit(ActiveStateHandler.java:268) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.imp.CoordinatorStateHandler.commitWithAfterCompletionNotification(CoordinatorStateHandler.java:581) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.imp.ActiveStateHandler.commit(ActiveStateHandler.java:263) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.imp.CoordinatorImp.commit(CoordinatorImp.java:548) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.imp.CoordinatorImp.terminate(CoordinatorImp.java:685) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.imp.CompositeTransactionImp.commit(CompositeTransactionImp.java:282) ~[transactions-4.0.6.jar!/:?]
at com.atomikos.icatch.jta.TransactionImp.commit(TransactionImp.java:172) ~[transactions-jta-4.0.6.jar!/:?]
at com.atomikos.icatch.jta.TransactionManagerImp.commit(TransactionManagerImp.java:414) ~[transactions-jta-4.0.6.jar!/:?]
at com.atomikos.icatch.jta.UserTransactionManager.commit(UserTransactionManager.java:159) ~[transactions-jta-4.0.6.jar!/:?]
at org.springframework.transaction.jta.JtaTransactionManager.doCommit(JtaTransactionManager.java:1034) ~[spring-tx-5.1.2.RELEASE.jar!/:5.1.2.RELEASE]
... 25 more
I ' Я чувствую, что что-то упустил в конфигурации atomikos, но не могу найти что.
Спасибо за вашу помощь.