Spring JMS监听器中的事务管理

我有一个正在监听队列的spring JMS监听器。一旦消息到达输入队列，它将对消息进行一定的处理，并将消息放到多个其他队列中以供进一步处理（我们可以将这些其他队列称为输出队列）。当它发布到其他输出队列时，如果将消息发布到其中一个输出队列可能会由于任何原因而失败，我想确保其他帖子输出在失败之前完成的队列被回滚。基本上我想确保它是原子操作。在监听器/容器上是否有任何注释/配置可用于在单个事务中实现此目的？Spring JMS监听器中的事务管理

这里是我使用

<jms:listener-container acknowledge="transacted" cache="session" connection-factory="jmsSecurityFactory" concurrency="1" container-type="default" container-class="abc.xyz"> 
<jms:listener id="listenerId" destination="inputQueue" ref="" /> 
</jms:listener-container> 
<beans:bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 
<beans:property name="sessionTransacted" value="true"></beans:property> 
<beans:property name="connectionFactory" ref="inCachingConnectionFactory"></beans:property> 
</beans:bean> 
<beans:bean id="inCachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> 
    <beans:property name="targetConnectionFactory" ref="jmsSecurityFactory" /> 
</beans:bean> 
<beans:bean id="jmsSecurityFactory" 
    class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"> 
    <beans:property name="targetConnectionFactory" ref="jmsConnectionFactory" /> 
    <beans:property name="username" value=" " /> 
    <beans:property name="password" value=" " /> 
</beans:bean> 
<beans:bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> 
    <beans:property name="hostName" value="${mq.conn.hostName}" /> 
    <beans:property name="port" value="${mq.conn.hostPort}" /> 
    <beans:property name="queueManager" value="${mq.conn.queueManager}" /> 
    <beans:property name="channel" value="${mq.conn.channel}" /> 
    <beans:property name="transportType" value="${mq.conn.transportType}" /> 
    <beans:property name="useConnectionPooling" value="true"></beans:property> 
</beans:bean>

它看起来像

来源

2015-01-02 KBR

设置acknowledge="transacted"听者容器JMS模板，并侦听容器都指向同一个连接工厂bean（jmsConnectionFactory）的配置;使用JmsTemplate（使用相同连接工厂配置）的同一线程上的任何下游操作将使用容器的Session，任何故障都将导致所有JMS操作回滚。会话将由容器承诺成功。

来源

2015-01-02 01:48:46

谢谢加里。我发布了配置。它看起来像确认属性设置为预期，并且JMS模板和容器都使用相同的连接工厂ulitmately。你在那里看到任何问题吗？ – KBR

“Ulitmately”不会削减它;它必须是对模板使用容器会话的同一连接工厂的引用。 –

谢谢加里。删除CachingConnectionFactory并将JMSTemplate和监听器指向相同的conn工厂（上面的configration中的jmsSecurityFactory）。 – KBR

Spring JMS监听器中的事务管理

回答

相关问题