如何使用Apache Camel在RabbitMQ消息上设置自定义头？

Question

我试图在我的邮件中添加自定义标题，所以每当异常发生并最终出现在死信队列中时，我都可以看到异常是什么。然而，我所有的尝试都失败了。

• 使用。setHeader（）
• 在outMessage上设置标题
• 正在设置exchange的属性

不允许将异常设置为有效负载中的属性。

@Component
public class ProcessRoute extends RouteBuilder {
    ...
    @Override
    public void configure() throws Exception {
        onException(Exception.class)
                .log("Error for ${body}! Requeue")
                .redeliveryDelay(2000)
                .maximumRedeliveries(3)
                .handled(true)
                .setHeader("TEST", constant("TEST"))
                .process(e -> {
                    e.getOut().setHeader("TEST", "TEST");
                    e.setProperty("TEST","TEST");
                });

        from(SOME_ROUTE)
          .doSomeStuff()
          .to(RABBITMQ);
    }
    ...
}

RABBITMQ字符串：

rabbitmq://foo
?exchangeType=topic
&addresses=localhost:1234
&routingKey=#
&autoDelete=false
&queue=bar
&autoAck=false
&deadLetterExchange=DLX
&deadLetterQueue=bar.dlq
&deadLetterExchangeType=direct
&deadLetterRoutingKey=#
&username=foo
&password=bar

Answer 1

如果按照Camel RabbitMQ组件已建立的模式使用头键，则在消息发布到RabbitMQ时，将拾取自定义头。

从上面的代码中提取，而不是：

.setHeader("TEST", constant("TEST"))

这样做：

.setHeader("rabbitmq.TEST", constant("TEST"))

Camel RabbitMQ组件似乎忽略了Camel exchange上可能存在的所有其他非“RabbitMQ.*”头，这可能是有原因的。在发布到RabbitMQ的消息的上下文中，可能会有很多，但大多数都没有意义。