Apache Camel动态toD配置问题：同时读取配置文件与交换属性

问题根源 #

你原来的配置${properties:rabbit.uri.${exchangeProperty.erpFlow}}搞反了解析顺序：Camel的properties组件会直接把rabbit.uri.${exchangeProperty.erpFlow}当成完整的属性键去查找，不会先解析${exchangeProperty.erpFlow}得到user.create，再拼成rabbit.uri.user.create去读取配置，自然找不到对应属性报错。

直接解决方案 #

调整嵌套引用的顺序，先用simple表达式解析交换属性生成完整配置键，再读取配置值。把toD改成下面这样：

<toD uri="rabbitmq:${properties:${simple:rabbit.uri.${exchangeProperty.erpFlow}}}"/>

解析流程 #

1. 先执行${simple:rabbit.uri.${exchangeProperty.erpFlow}}：解析exchangeProperty.erpFlow拿到user.create，拼接出配置键rabbit.uri.user.create。
2. 再执行${properties:...}：根据这个配置键读取配置文件里对应的URI片段。
3. 最后自动拼成完整的RabbitMQ端点URI，就能生成你要的目标地址了。

验证配置匹配 #

要确保你的配置文件里这些参数是对的：

• rabbit.exchanges.customersDead的值是MyExchange
• rabbit.exchangeArgs的值是exchangeType=topic&bridgeEndpoint=true
• rabbit.dlqConcurrentConsumers的值是2

这样运行时就能生成你期望的URI：

<toD uri="rabbitmq:MyExchange?exchangeType=topic&amp;bridgeEndpoint=true&amp;queue=org.user.create&amp;concurrentConsumers=2&amp;skipQueueDeclare=false"/>

备选方案（手动构造URI） #

如果上面的写法还是有问题，可以加个处理器提前把URI拼好存到交换属性里，再用toD引用：

Java DSL写法 #

from("你的输入端点")
    .process(exchange -> {
        String erpFlow = exchange.getProperty("erpFlow", String.class);
        String configKey = "rabbit.uri." + erpFlow;
        String uriFragment = exchange.getContext().resolvePropertyPlaceholders("${" + configKey + "}");
        exchange.setProperty("rabbitTargetUri", "rabbitmq:" + uriFragment);
    })
    .toD("${exchangeProperty.rabbitTargetUri}");

XML DSL写法 #

<route>
    <from uri="你的输入端点"/>
    <process>
        <bean method="buildRabbitUri" ref="rabbitUriBuilder"/>
    </process>
    <toD uri="${exchangeProperty.rabbitTargetUri}"/>
</route>

<!-- 对应的处理器Bean -->
<bean id="rabbitUriBuilder" class="你的包名.RabbitUriBuilder"/>

处理器类代码 #

public class RabbitUriBuilder {
    public void buildRabbitUri(Exchange exchange) {
        String erpFlow = exchange.getProperty("erpFlow", String.class);
        String configKey = "rabbit.uri." + erpFlow;
        String uriFragment = exchange.getContext().resolvePropertyPlaceholders("${" + configKey + "}");
        exchange.setProperty("rabbitTargetUri", "rabbitmq:" + uriFragment);
    }
}

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