带有收件人列表的 Apache Camel 路由

Question

我正在尝试使用 org.apache.camel 动态路由消息。

这是我的代码：

from("direct:messenger")
            .routeId("messenger-provider")
            .bean(messengerService, "process")
            .marshal().json(JsonLibrary.Jackson)
            .setHeader(Exchange.HTTP_METHOD, constant("POST"))
            .recipientList(header("access_token")).ignoreInvalidEndpoints()

这是我的服务类的相关部分：

    exchange.getIn().setHeader("access_token", messengerServiceEndpoint.getEndpointUri()+"?access_token="+accessToken);

实际上我想将 access_token 动态添加到端点 URI。但我只能从服务类中获取令牌。

如果有人有一些很棒的见解，谢谢

Answer 1

我认为您正在寻找的是 org.apache.camel.impl.JndiRegistry 或 org.apache.camel.impl.SimpleRegistry：

您可以将您的对象绑定到注册表并检索您需要的位置。

http://camel.apache.org/registry.html

查看此链接以创建 SimpleRegistry 并在 Java DSL 中使用：

http://preparationforinterview.com/preparationforinterview/camel-spring-bean-javadsl

下面是关于创建 JNDIRegistry 的 stackoverflow 问题：

camel - get jndi registry

如果你使用的是 Spring，那么你可以使用 ApplicationContextRegistry：

ApplicationContextRegistry registry = exchange.getContext().getRegistry(ApplicationContextRegistry.class);
Map<String,Object>map = (Map<String,Object>)registry.lookup("map");
map.put("objectVar", objectVar);

在你的 Spring 配置中有一个地图来加载对象：

<bean id="map" class="java.util.HashMap"></bean>

检索对象：

Map<String,Object> map = (Map<String,Object>)registry.lookup("map");
    Object1 o = (Object1) map.get("objectVar");