Добрый день всем! Хочу использовать ActiveMQ для отправки сообщения в очередь при изменении данных в БД (Sybase). Для управления транзакциями БД в приложении используется Spring DataSourceTransactionManager. Для отправки сообщений в очередь использую JmsTemplate. Проблема заключается в том, что нужно в рамках одной транзакции сделать примерно слюдующие действия:
Шаг 1: апдэйт БД;
Шаг 2: отправка сообщения в очередь;
Шаг 3: апдэйт БД;
Шаг 4: отправка сообщения в очередь.
Если на каком-то этапе возникает исключение - нужно откатить всю транзакцию целиком. Как я понял из документации по JmsTemplate, в моём случае я должен установить параметр "sessionTransacted" = true:
| Цитата |
Setting this flag to "true" will use a short local JMS transaction when running outside of a managed transaction, and a synchronized local JMS transaction in case of a managed transaction (other than an XA transaction) being present. The latter has the effect of a local JMS transaction being managed alongside the main transaction (which might be a native JDBC transaction), with the JMS transaction committing right after the main transaction.
|
Конфигурационный файл для JMS содержит только две секции:
| Код |
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" ref="url"/>
<property name="userName" ref="username"/>
<property name="password" ref="password"/>
</bean>
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="defaultDestinationName" value="SomeQueue"/>
<property name="sessionTransacted" value="true"/>
</bean>
|
Решил проверить работоспособность этого, кидая запросы на два простых метода, которые прикрутил к контроллеру:
| Код |
@Transactional
public void sendMessageTransactionalErr(Object message, List<String> queueDestinationNames) throws Exception {
sender.sendMessage(message, queueDestinationNames);
throw new Exception("FatalException!");
}
|
| Код |
@Transactional
public void sendMessageTransactionalOK(Object message, List<String> queueDestinationNames) throws Exception {
sender.sendMessage(message, queueDestinationNames);
}
|
Но в обоих случаях сообщение попадает в очередь. Даже если возникает исключение (в методе sendMessageTransactionalErr), и происходит роллбэк транзакции JDBC, JMS-ная транзакция всё равно завершается успешно. Что я должен сделать, чтобы заставить эту схему работать так как мне нужно?
|
