Apache Camel onException处理：如何将错误详情附加至原始消息并发送至错误队列（配置后无法获取自定义头部）

我来帮你排查这个问题，你的核心需求是把原始消息和错误详情头部一起发送到错误队列，现在头部丢失的原因主要是没有正确保留原始消息上下文，下面是具体的解决方案：

问题根源 #

当你使用.handled(true)时，Camel会标记异常已处理并继续路由当前Exchange，但此时的Exchange可能已经不是触发异常的原始消息上下文——默认情况下，异常处理流程不会自动保留原始消息的全部内容，导致你设置的自定义头部和原始消息没有正确绑定在一起。

最优解决方案：使用copyOriginalMessage() #

Camel提供了内置的copyOriginalMessage()方法，它会自动将触发异常的原始消息完整复制到当前处理的Exchange中，这样你设置的自定义头部就会附加在原始消息上，一起发送到错误队列。修改后的路由代码如下：

.onException(BeanCreationException.class, ValidationException.class)
    .handled(true)
    .copyOriginalMessage() // 关键：保留触发异常的原始消息
    .process(new OnExceptionProcessor())
    .to("errorQueue0").id("errorQueue")
.end()

你的OnExceptionProcessor不需要修改，它会在原始消息的基础上添加FailedBecause头部，最终发送到errorQueue0的消息就是原始消息体 + 错误详情头部的完整内容。

备选方案：手动复制原始消息（适合更复杂的场景） #

如果需要更精细的控制，你也可以在处理器中手动获取并复制原始消息，代码如下：

public class OnExceptionProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        // 获取触发异常的原始消息
        Message originalMsg = exchange.getProperty(Exchange.ORIGINAL_MESSAGE, Message.class);
        if (originalMsg != null) {
            // 将原始消息的内容、头部等全部复制到当前In消息中
            exchange.getIn().copyFrom(originalMsg);
        }
        // 添加错误详情头部
        Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
        exchange.getIn().setHeader("FailedBecause", cause.getMessage());
    }
}

这种方式适合需要对原始消息做额外修改的场景，比如过滤某些头部、修改消息体等。

额外注意事项 #

• 确保你使用的消息队列组件（如ActiveMQ、Kafka等）支持传递自定义头部，部分组件对头部的类型有序列化要求（FailedBecause是字符串，完全兼容）。
• 如果你的路由中有多个异常处理分支，注意copyOriginalMessage()的作用范围，避免消息内容被意外覆盖。

内容的提问来源于stack exchange，提问作者Rohit