Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

28.5. Samples

JMS 也在许多示例中用于其他组件。但是，我们提供了几个示例来开始。

28.5.1. 从 JMS 接收
复制链接

在以下示例中，我们将配置一个路由，该路由接收 JMS 信息并将消息路由到 POJO： 

from("jms:queue:foo").
   to("bean:myBusinessLogic");
Copy to Clipboard Toggle word wrap

您可以使用任何 EIP 模式，以便路由基于上下文。例如，这里的如何为大消耗器过滤订购主题： 

from("jms:topic:OrdersTopic").
  filter().method("myBean", "isGoldCustomer").
  to("jms:queue:BigSpendersQueue");
Copy to Clipboard Toggle word wrap

28.5.2. 发送到 JMS
复制链接

在以下示例中，我们轮询文件文件夹，并将文件内容发送到 JMS 主题。当我们希望将文件的内容作为 TextMessage 而不是 BytesMessage 一样，我们需要将正文转换为 字符串 ： 

from("file://orders").
  convertBodyTo(String.class).
  to("jms:topic:OrdersTopic");
Copy to Clipboard Toggle word wrap

28.5.3. 使用注解
复制链接

Camel 还具有注释，因此您可以使用 POJO Consuming 和 POJO Producing。

28.5.4. Spring DSL 示例
复制链接

前面的示例使用 Java DSL。Camel 还支持 Spring XML DSL。以下是使用 Spring DSL 的大消耗的示例： 

<route>
  <from uri="jms:topic:OrdersTopic"/>
  <filter>
    <method ref="myBean" method="isGoldCustomer"/>
    <to uri="jms:queue:BigSpendersQueue"/>
  </filter>
</route>
Copy to Clipboard Toggle word wrap

28.5.5. 其他示例
复制链接

JMS 出现在其他组件和 EIP 模式的许多示例中，以及此 Camel 文档。因此，可以浏览文档。

28.5.6. 使用 JMS 作为 Dead Letter Queue Store Exchange
复制链接

通常，当使用 JMS 作为传输时，它仅传输正文和标头作为有效负载。如果要将 JMS 与 Dead Letter Channel 搭配使用，使用 JMS 队列作为 Dead Letter Queue，则原因的例外通常不会存储在 JMS 消息中。但是，您可以在 JMS 死信队列中使用 transferExchange 选项来指示 Camel 将整个 Exchange 存储在队列中，作为包含 org.apache.camel.support.DefaultExchangeHolder 的 javax.jms.ObjectMessage。这可让您从 Dead Letter Queue 中使用，并使用密钥 Exchange.EXCEPTION_CAUGHT 从 Exchange 属性中检索原因异常。以下演示展示了这一点： 

// setup error handler to use JMS as queue and store the entire Exchange
errorHandler(deadLetterChannel("jms:queue:dead?transferExchange=true"));
Copy to Clipboard Toggle word wrap

然后，您可以从 JMS 队列中消耗并分析问题： 

from("jms:queue:dead").to("bean:myErrorAnalyzer");

// and in our bean
String body = exchange.getIn().getBody();
Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
// the cause message is
String problem = cause.getMessage();
Copy to Clipboard Toggle word wrap

您可以使用 JMS 存储原因错误消息或存储自定义正文，您可以自行初始化。以下示例使用 Message Translator EIP 在移到 JMS 死信队列前对失败的交换进行转换： 

// we sent it to a seda dead queue first
errorHandler(deadLetterChannel("seda:dead"));

// and on the seda dead queue we can do the custom transformation before its sent to the JMS queue
from("seda:dead").transform(exceptionMessage()).to("jms:queue:dead");
Copy to Clipboard Toggle word wrap

在这里，我们只会将原始原因错误消息存储在转换中。但是，您可以使用任何表达式来发送您需要的任何表达式。例如，您可以在 Bean 上调用方法或使用自定义处理器。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat