Дважды исключенные сообщения JMS с использованием ActiveMq и Atomikos - PullRequest
2 голосов
/ 29 февраля 2012

Я использую ActiveMq в качестве сервера JMS, а Atomikos - в качестве менеджера транзакций.

В веб-интерфейсе администратора ActiveMq я вижу, что одно сообщение было поставлено в очередь, но 2 (!) Сообщения были сняты.

Тем не менее, jms-обработчик сообщения обрабатывает только один раз, при обработке дублирование отсутствует.Когда я использую простой Spring JmsTransactionManager, есть одно сообщение в очереди и одно в очереди.Проблема возникает только для диспетчера транзакций Atomikos JTA.

В чем проблема?Как настроить Atomikos, чтобы не видеть дважды снятые сообщения?

Моя конфигурация ниже.Это почти так же, как в учебнике.Кстати, весенний пример интеграции Atomikos работает хорошо, но он использует Spring 2.0, тогда как я использую Spring 3.1.

<bean id="activeMqXaConnectionFactory" class="org.apache.activemq.spring.ActiveMQXAConnectionFactory">
    <property name="brokerURL" value="tcp://localhost:61616"/>
</bean>

<bean id="atomikosQueueConnectionFactory" class="com.atomikos.jms.QueueConnectionFactoryBean" init-method="init">
    <property name="resourceName" value="xaMq"/>
    <property name="xaQueueConnectionFactory" ref="activeMqXaConnectionFactory"/>
</bean>

<bean id="singleConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory" ref="atomikosQueueConnectionFactory"/>
</bean>

<bean id="jmsDefaultContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="singleConnectionFactory"/>
    <property name="messageListener" ref="consumer"/>
    <property name="concurrentConsumers" value="1"/>
    <property name="destinationName" value="q.jtaxa"/>
    <property name="receiveTimeout" value="3000"/>
    <property name="recoveryInterval" value="5000"/>
    <property name="transactionManager" ref="transactionManager"/>
    <property name="sessionTransacted" value="true"/>
</bean>

<!-- Transactions -->
<!--Construct Atomikos UserTransactionManager, needed to configure Spring-->
<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init"
      destroy-method="close">
    <!--  when close is called, should we force transactions to terminate or not? -->
    <property name="forceShutdown" value="true"/>
</bean>

<!-- Also use Atomikos UserTransactionImp, needed to configure Spring  -->
<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
    <property name="transactionTimeout" value="300"/>
</bean>

<!-- Configure the Spring framework to use JTA transactions from Atomikos -->
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" ref="atomikosTransactionManager"/>
    <property name="userTransaction" ref="atomikosUserTransaction"/>
    <property name="nestedTransactionAllowed" value="true"/>
</bean>

Потребительский класс:

@Component
public class Consumer implements MessageListener {
  @Override
  public void onMessage(Message message) {
    if (message instanceof TextMessage) {
        try {
            TextMessage textMsg = (TextMessage) message;
            System.out.println("         " + textMsg.getText());
        } catch (JMSException ex) {
            ex.printStackTrace();
        }
    }
  }
}

1 Ответ

1 голос
/ 01 марта 2012

Я нашел то, что было неправильно настроено. Это была "atomikosQueueConnectionFactory". Я сделал согласие с учебником, но это должен быть просто класс AtomikosConnectionFactoryBean, а не QueueConnectionFactoryBean. Я удалил atomikosQueueConnectionFactory и добавил atomikosConnectionFactory

<bean id="atomikosConnectionFactory" class="com.atomikos.jms.AtomikosConnectionFactoryBean" init-method="init">
    <property name="uniqueResourceName" value="amq1"/>
    <property name="xaConnectionFactory" ref="mqXaConnectionFactory"/>
</bean>

После этого все работает нормально. Я нашел правильную конфигурацию здесь .

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...