Apache Camel异常处理器获取原始消息报错：如何开启AllowUseOriginalMessage？

问题原因 #

调用exchange.getUnitOfWork().getOriginalInMessage()抛出IllegalStateException，是因为Camel默认禁用了原始消息的存储功能，需手动开启后才能访问原始消息。

开启方式 #

1. Java DSL 配置 #

在路由构建阶段，通过allowUseOriginalMessage()方法开启：

from("direct:start")
    .allowUseOriginalMessage() // 开启原始消息访问权限
    .process(exchange -> {
        // 业务处理逻辑
    })
    .onException(Exception.class)
        .process(exchange -> {
            // 此时可安全获取原始消息
            Message originalMsg = exchange.getUnitOfWork().getOriginalInMessage();
            // 异常处理逻辑
        })
    .end();

2. Spring XML 配置 #

在路由节点上添加allowUseOriginalMessage="true"属性：

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route allowUseOriginalMessage="true">
        <from uri="direct:start"/>
        <process ref="businessProcessor"/>
        <onException>
            <exception>java.lang.Exception</exception>
            <process ref="exceptionProcessor"/>
        </onException>
    </route>
</camelContext>

3. Spring Boot 全局配置 #

若使用Spring Boot，可在配置文件中全局开启：

# application.properties
camel.context.allow-use-original-message=true

或YAML格式：

# application.yml
camel:
  context:
    allow-use-original-message: true

注意事项 #

• 开启该功能会存储原始消息副本，可能增加内存开销，按需启用即可。
• 必须在路由初始化阶段开启，无法在异常处理器内部动态启用。

内容的提问来源于stack exchange，提问作者lance-java