25.10. 重复使用端点,并在运行时发送到不同目的地计算


如果您需要向许多不同的 JMS 目的地发送消息,可以重复使用 JMS 端点并在消息标头中指定实际目的地。这样,Camel 可以重复使用同一端点,但会发送到不同的目的地。这可大大减少在内存和线程资源中创建的端点数量。

您可以在以下标头中指定目的地:

Expand
标头类型描述

CamelJmsDestination

javax.jms.Destination

目标对象。

CamelJmsDestinationName

字符串

目标名称。

例如,以下路由演示了如何在运行时计算目的地,并使用它来覆盖 JMS URL 中出现的目的地:

from("file://inbox")
  .to("bean:computeDestination")
  .to("activemq:queue:dummy");
Copy to Clipboard Toggle word wrap

队列名称 dummy 只是一个占位符。它必须作为 JMS 端点 URL 的一部分提供,但本例中将被忽略。

computeDestination bean 中,通过设置 CamelJmsDestinationName 标头来指定真实目的地,如下所示:

public void setJmsHeader(Exchange exchange) {
   String id = ....
   exchange.getIn().setHeader("CamelJmsDestinationName", "order:" + id");
}
Copy to Clipboard Toggle word wrap

然后,Camel 将读取此标头并将其用作目标,而不是端点中配置的目标。因此,在本示例中,Camel 将消息发送到 activemq:queue:order:2,假设 id 值为 2。

如果同时设置了 CamelJmsDestinationCamelJmsDestinationName 标头,CamelJmsDestination 都会具有优先权。请记住,JMS producer 会从交换中删除 CamelJmsDestinationCamelJmsDestinationName 标头,且不将其传播到创建的 JMS 消息,以避免路由中的意外循环(在消息将转发到另一个 JMS 端点时)。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat