java – Spring JMS侦听器中的事务管理

发布时间：2020-12-15 01:34:52 所属栏目：大数据来源：网络整理

导读：我有一个正在侦听队列的spring JMS侦听器.一旦消息到达输入队列,它就对消息进行某些处理,并将消息放到多个其他队列中进行进一步处理(我们可以将这些其他队列称为输出队列).当它发布到其他输出队列时,如果将消息发布到其中一个输出队列可能由于任何原因而失败

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

这是我正在使用的配置


它看起来像JMS模板和监听器容器都引用相同的连接工厂bean(jmsConnectionFactory)


最佳答案
在侦听器容器上设置acknowledge =“transacted”;使用JmsTemplate(使用相同的连接工厂配置)在同一线程上的任何下游操作都将使用容器的Session,任何失败都将导致所有JMS操作回滚.会话将由容器成功提交.
                        （编辑：李大同）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!