使用 Spring 管理 JMS 事务答案

【问题标题】：Managing JMS transaction with Spring使用 Spring 管理 JMS 事务
【发布时间】：2012-10-31 16:16:56
【问题描述】：

我正在尝试使用 Spring 和 HornetQ 管理 JMS 事务。
这是我写的代码：

public void receive() {
    TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());
    Message msg = jmsTemplate.receive(queue);
    boolean success = false;
    if (msg != null) {
            try {
               success = handleMessage(msg);
               if (success) { 
                   msg.acknowledge(); // session is still open within the transaction
               }
            } catch (JMSException e) {
                transactionManager.rollback(status);
            }
            if (success)
                transactionManager.commit(status);
            else
                transactionManager.rollback(status):
    }
}

我正在从队列中同步读取，超时设置为 0，因为我不想阻塞读取。因此，我必须检查是否真的收到了东西。

这是我的 applicationContext.xml 的摘录：

<bean id="inVMConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName">
        <value>java:/ConnectionFactory</value>
    </property>
</bean>

<bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="inVMConnectionFactory" />
</bean>

<bean id="producer" class="it.ubiquity.gestoreprofilazione.onweb.OnWebProducer" scope="singleton">
    <property name="queue" ref="retryQueue" />
    <property name="connectionFactory" ref="cachedConnectionFactory" />
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="cachedConnectionFactory" />
    <property name="sessionTransacted" value="true" />
    <property name="sessionAcknowledgeMode" value="#{T(javax.jms.Session).CLIENT_ACKNOWLEDGE}" />
    <property name="pubSubDomain" value="false" />
    <property name="receiveTimeout" value="#    {T(org.springframework.jms.core.JmsTemplate).RECEIVE_TIMEOUT_NO_WAIT}" />
</bean>

<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
    <property name="connectionFactory" ref="cachedConnectionFactory" />
</bean>

<bean id="consumer" class="it.ubiquity.gestoreprofilazione.onweb.OnWebConsumer" scope="singleton">
    <property name="queue" ref="retryQueue" />
    <property name="jmsTemplate" ref="jmsTemplate" />
    <property name="transactionManager" ref="jmsTransactionManager" />
</bean>

我遇到的问题比较奇怪：第一次收到消息，handleMessage失败，所以我回滚事务。然后没有更多的事情发生。如果我检查 JMX 控制台，我可以看到队列中有一条消息。现在，如果我重新启动 JBoss，消息会按预期一次又一次地接收。
可能是我的配置有问题，为什么重启后就可以了？

HornetQ 2.2.10
JBoss 5.1.0
春季 3.1.2

更新
启用调试后，我第一次看到：

调试 [org.springframework.jms.connection.JmsTransactionManager] (baseScheduler-1) 创建名称为 [null] 的新事务： PROPAGATION_REQUIRED,ISOLATION_DEFAULT

在第一次回滚之后，在随后的接收和回滚中我看到：

调试 [org.springframework.jms.connection.JmsTransactionManager] (baseScheduler-1) 参与现有事务

相反，重启JBoss后，我读到事务实际上是回滚的：

调试 [org.springframework.jms.connection.JmsTransactionManager] (baseScheduler-1) 发起事务回滚 2012-11-05 09:54:14,436 调试 [org.springframework.jms.connection.JmsTransactionManager] (baseScheduler-1) 在 Session 上回滚 JMS 事务

那么，为什么回滚不是第一次发生，而一旦我重新启动服务器，它就会一直发生？我做错了什么？

【问题讨论】：

标签： spring jboss jms hornetq spring-jms

【解决方案1】：

好吧，我终于明白我的错误了 :) 在外部 if 的 else 我应该提交事务。这就是重新启动 JBoss 后该机制起作用的原因：没有事务挂起。

【讨论】：