【发布时间】:2014-11-26 23:39:11
【问题描述】:
我需要从两个队列加载消息并且我正在使用 ActiveMQ 我必须实现重试机制以防出现任何错误或网络或应用程序服务器故障并加载回同一个队列。另外,我想将任何有毒消息加载到 DLQ。
如果我可以通过 Spring JMS 实现这些,请告诉我。另外,请提供一些好的例子来完成这项任务。我检查了 Spring JMS 文档并没有太多细节。
【问题讨论】:
标签: activemq spring-jms
我需要从两个队列加载消息并且我正在使用 ActiveMQ 我必须实现重试机制以防出现任何错误或网络或应用程序服务器故障并加载回同一个队列。另外,我想将任何有毒消息加载到 DLQ。
如果我可以通过 Spring JMS 实现这些,请告诉我。另外,请提供一些好的例子来完成这项任务。我检查了 Spring JMS 文档并没有太多细节。
【问题讨论】:
标签: activemq spring-jms
这是 ActiveMQ 的代理功能 - 只需使用适当的策略配置代理即可。
如果使用DefaultMessageListenerContainer,则必须使用事务会话;然后,如果侦听器抛出异常,则消息将回滚到队列中,并且代理的重试/DLQ 策略启动。
请参阅the Spring documentation 了解启用事务。
【讨论】: