我正在使用spring云流来使用来自兔子MQ的消息。我有一个队列和死信队列绑定到它。无论何时出现异常,消息都会被路由到死信队列。
我的问题是-,我们可以在异常类中放置一个消息头,然后在死信队列中接收它。或者,我们如何通过查看消息来知道哪个异常发生了。I想要根据异常修复、重新排队或停放消息。
发布于 2019-01-16 13:57:45
当被RabbitMQ本身发送到DLQ时,您不能修改被拒绝的消息;为此,绑定程序提供了一个使用者属性republishToDlq,其中,而不是拒绝消息并让RabbitMQ将其发送到DLQ,绑定器本身在那里发布它,并添加带有异常信息的标头等。
https://stackoverflow.com/questions/54215248
复制相似问题