Spring、XA 和 WebSphere

Question

我正在尝试让 XA 事务在 WebSphere v7 内的 Spring v3 应用程序中工作。

我的应用程序上下文显示：

<bean id="jmsConnectionFactory" 
        class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="jms/MQConnectionFactory"/>
    <property name="resourceRef" value="true"/>
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
</bean>

<jee:jndi-lookup id="myDB" jndi-name="jdbc/myDB"/>

<bean id="txManager"
    class="org.springframework.transaction.jta.WebSphereUowTransactionManager" />

<tx:annotation-driven transaction-manager="txManager"/>

我正在引用这篇文章，上面写着混入 UOW txn 管理器，就可以了。但事实并非如此。相反，在以下代码中，消息被破坏性地读取，并且在引发异常时不回滚。

事务逻辑是（在scala中）：

@Transactional(rollbackFor = Array(classOf[Throwable]))
def processNextMessage(category: String) = {
  val maybeMessage = readNextMessage(category) // <- this is a destructive read

  for (message <- maybeMessage) {
    // this is temporary code for testing
    throw new RuntimeException("blaaaaaah")
    // end temporary code

    // sendToQueue(message, queue)
    // writeToMessageStore(message)
  }
}

任何人都可以建议我如何将WebSphere的JTA事务管理器与Spring一起使用？

Answer 1

首先，我真的很想看到 readNextMessage 的代码，因为这可能是罪魁祸首。

队列连接工厂是否设置为 XA 资源。您正在尝试使用 JTA 进行事务，因此据我所知您需要相应地配置消息 qcf。

您不必为事务设置 JmsTemplate，因为这些事务由 QueueConnectionFactory 处理。

附带说明：如果您只是处理 mq，则可以跳过 UOW JTA 提供程序并使用事务处理 JMS 会话，这应该可以正常工作。