请求时自定义 header
Custom header when requeing
我正在使用 SimpleMessageListenerContainer 接收来自 RabbitMq 的消息。有没有办法在消息被拒绝时将自定义元数据添加到消息中?我想从失败的地方继续处理消息。
我假设从侦听器抛出的任何异常都会导致消息重新排队(前提是为此设置了异常)。
谢谢,
苏达
没有。 amqp 协议只有一个简单的标志来重新排队。您可以将重试与 RepublishMessageRecoverer 的子类一起使用以添加 headers,但它会在尾部而不是头部重新排队。请参阅参考手册。
我正在使用 SimpleMessageListenerContainer 接收来自 RabbitMq 的消息。有没有办法在消息被拒绝时将自定义元数据添加到消息中?我想从失败的地方继续处理消息。
我假设从侦听器抛出的任何异常都会导致消息重新排队(前提是为此设置了异常)。
谢谢, 苏达
没有。 amqp 协议只有一个简单的标志来重新排队。您可以将重试与 RepublishMessageRecoverer 的子类一起使用以添加 headers,但它会在尾部而不是头部重新排队。请参阅参考手册。