Трассировка исключения в заголовке сообщения в очереди недоставленных сообщений

Question

Я использую spring-cloud-stream для получения сообщения от Rabbit MQ. У меня есть очередь и привязка к мертвой букве. Всякий раз, когда возникает какое-либо исключение, сообщения направляются в очередь недоставленных сообщений.

Мой вопрос - Можем ли мы поместить заголовок в сообщение с классом Exception до получения его в очереди недоставленных сообщений. Или, как мы узнаем, какое исключение произошло, посмотрев на сообщение. Я хочу восстановить, поставить в очередь или оставить сообщения на основе исключения.

Answer 1

Вы не можете изменить отклоненное сообщение, когда оно отправлено в DLQ самим RabbitMQ; по этой причине связыватель предоставляет свойство потребителя republishToDlq, где вместо того, чтобы отклонить сообщение и заставить RabbitMQ отправить его в DLQ, связыватель сам публикует его там и добавляет заголовки с информацией об исключениях и т. д.