我有一个正在侦听队列的spring JMS侦听器.一旦消息到达输入队列,它就对消息进行某些处理,并将消息放到多个其他队列中进行进一步处理(我们可以将这些其他队列称为输出队列).当它发布到其他输出队列时,如果将消息发布到其中一个输出队列可能由于任何原因而失败,我想确保在故障之前完成的输出队列的其他帖子被回滚.基本上我想确保它作为原子操作.
在侦听器/容器上是否有任何注释/配置可用于在单个事务中实现此目的.
这是我正在使用的配置
它看起来像JMS模板和监听器容器都引用相同的连接工厂bean(jmsConnectionFactory)
最佳答案
在侦听器容器上设置acknowledge =“transacted”;使用JmsTemplate(使用相同的连接工厂配置)在同一线程上的任何下游操作都将使用容器的Session,任何失败都将导致所有JMS操作回滚.会话将由容器成功提交.
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。