java - 使用 useExponentialBackOff 重新传递 HornetQ 消息

Question

在ActiveMQ中，可以在重新传递策略中设置useExponentialBackOff，这会在每次消息消费失败时以指数方式增加延迟。如何在HornetQ中实现这一点？

是否可以将自己的重新传递策略定义为 java 类？

Answer 1

它应该有效:

<address-settings>
      <address-setting match="jms.queue.example">
         <dead-letter-address>jms.queue.deadletter</dead-letter-address>
         <max-delivery-attempts>5</max-delivery-attempts>
         <redelivery-delay>1000</redelivery-delay>
         <redelivery-delay-multiplier>2.0</redelivery-delay-multiplier>
      </address-setting>
</address-settings>

• redelivery-delay-multiplier:这允许您实现重新投递尝试之间的指数退避。
• max-delivery-attempts:消息将转发到死信地址(如果指定)，
  在最大交付尝试次数不成功的尝试之后。
• 重新投递延迟:HornetQ 将在重新投递之前等待此延迟消息