0

我的实际代码（Camel 2.10.x）创建一个新的 Camel 消息来包装一些数据（http 查询），如下所示：

Message message = new DefaultMessage();
message.setHeader(HEADER_QUERY, query);
message.setHeader(HEADER_BRAND, brand);
message.setHeader(HEADER_LIST_ID, listId);

当我迁移我的平台时，我们使用的 Camel 版本是：2.23.0，我们现在可以看到空的构造函数已被弃用。执行代码时，我们遇到了与官方 Camel 论坛的这篇文章中提到的相同的问题。

好方法似乎是通过使用带有 CamelContext in 参数的构造函数来创建消息，如下所示：

Message message = new DefaultMessage(camelContext);
message.setHeader(HEADER_QUERY, query);
message.setHeader(HEADER_BRAND, brand);
message.setHeader(HEADER_LIST_ID, listId);

我在 OSGI 上下文中，但代码在我没有Exchange原始Message可用的 Bean 中。我只是想知道如何CamelContext向 Message 构造函数提供，或者是否有另一种方法可以在DefaultMessage没有 CamelContext 的情况下创建。

请注意，我不在 Camel Route 中，Bean 是从 REST 接口调用的（我怀疑有一些重构来清理它，但我们计划很快停用它）。我正在寻找一个速赢的解决方案。

4

2 回答 2

0

你可以试试org.apache.camel.main.Main上课。它是一个单例，所以你可以通过使用来获取实例Main.getInstance()，然后你可以调用getOrCreateCamelContext()方法来获取CamelContext。

于 2019-12-03T13:48:43.220 回答
0

不幸的是，解决方案Main.getInstance().getOrCreateCamelContext()似乎在我的上下文（OSGI）中不起作用：Main.getInstance()总是返回null。

但我终于找到了另一种让它工作的方法：

第一步

将 bundleContext 注入我的 Bean：

<bean id="myCustomMessageFactory" class="org.mycompany.module.factory.CustomMessageFactory">
    <property name="bundleContext" ref="blueprintBundleContext" />
</bean>

是自动设置的blueprintBundleContext，不需要声明。

第二步

来自 Bean（Java 代码）：

ServiceReference sr = bundleContext.getServiceReference(CamelContext.class);
CamelContext camelContext = (CamelContext) bundleContext.getService(sr);
// and then I can inject the camelContext into the message constructor
Message message = new DefaultMessage(camelContext);

它在 OSGI 环境中完美运行。

于 2021-01-25T23:04:44.523 回答