如何解决RabbitMQ:在使用 DLX 策略发送到 DLQ 之前向消息头添加异常
您能否建议一种方法,在使用 RabbitMQ 中的 dlx 策略将异常发送到 DLQ 之前,将异常添加到我的原始消息标头中
我尝试用aspect来做,但我改变的消息不是推送到DLQ的消息,这是正常的,代理中的原始消息总是被发布。
@Service
@RabbitListener(queues = "queueName")
public class Listener {
@RabbitHandler
public void receive(Basicmessage message) {
try {
doSomeWork();
} catch(Exception e) {
}
}
}
解决方法
消息必须以编程方式重新发布;如果代理只是将消息重新路由到 DLQ,则您无法修改消息。
框架提供了一种机制来做到这一点。
printf( "value of x = %d,address of x = %p\n",x,(void *) &x );
printf( "value of p = %p,address of p = %p\n",(void *) p,(void *) &p );
printf( "value of q = %p,address of q = %p\n",(void *) q,(void *) &q );
printf( "value of r = %p,*r = %p,**r = %p,***r = %d\n",(void *) r,(void *) *r,(void *) **r,***r );
在消息头中发布带有附加信息的消息,例如异常消息、堆栈跟踪、原始交换和路由密钥。可以通过创建子类并覆盖 void *
来添加其他标头。 RepublishMessageRecoverer
(或任何其他属性)也可以在 additionalHeaders()
中更改。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。