红帽全球峰会6.2. camel-jms
有两种支持的方法将 camel-jms、camel-sjms 和 camel-sjms2 端点连接到远程 AMQ 7 代理。
- 使用 pooled-connection-factory 配置远程连接器，如"JBoss EAP 配置消息传递指南》中的"配置" Resource Adapter to Connect to Red Hat JBoss AMQ 7 一节中所述。
- 使用 connection-factory 配置远程连接器，如 使用 connection-factory 配置远程连接器
第一个选项是首选的方法，因为它提供连接池和 XA 事务支持。
对于使用持久订阅者的消息传递场景，由于 JavaEE 7 规格所施加的限制，JBoss EAP 上的 Fuse 7.11 不支持 pooled-connection-factory。在这种情况下，最好配置标准未池连接。
使用 connection-factory 配置远程连接器
创建一个指向远程消息传递服务器的出站套接字绑定：
/socket-binding-group=standard-sockets/remote-destination-outbound-socket-binding=messaging-remote-throughput:add(host=localhost, port=61616)
/socket-binding-group=standard-sockets/remote-destination-outbound-socket-binding=messaging-remote-throughput:add(host=localhost, port=61616)Copy to Clipboard Copied! Toggle word wrap Toggle overflow 创建引用在第 1 步中创建的出站套接字绑定的远程连接器。
/subsystem=messaging-activemq/server=default/remote-connector=netty-remote-throughput:add(socket-binding=messaging-remote-throughput)
/subsystem=messaging-activemq/server=default/remote-connector=netty-remote-throughput:add(socket-binding=messaging-remote-throughput)Copy to Clipboard Copied! Toggle word wrap Toggle overflow 创建连接因素，引用第 2 步中创建的远程连接器。
/subsystem=messaging-activemq/server=default/connection-factory=simple-remote-artemis-connection-factory:add(entries=[java:/jms/RemoteJms],connectors=[netty-remote-throughput])
/subsystem=messaging-activemq/server=default/connection-factory=simple-remote-artemis-connection-factory:add(entries=[java:/jms/RemoteJms],connectors=[netty-remote-throughput])Copy to Clipboard Copied! Toggle word wrap Toggle overflow
6.2.1. 消息传递代理和客户端
摘要
Fuse 7.11 不提供默认的内部消息传递代理，但它旨在与外部 JMS 代理进行接口。
JBoss EAP 上的 Fuse 7.11 使用在 JBoss EAP 上配置消息传递 代理时详述的资源适配器。
有关 JBoss EAP 上 Fuse 7.11 上可用的外部代理、JCA 适配器和 Camel 组件组合的更多信息，请参阅支持的配置。https://access.redhat.com/articles/310603
有关使用 JMS 的 JBoss EAP 上 Fuse 连接到外部代理的更多信息，请参阅 第 6.2 节 “camel-jms”。
Camel-jms Quickstart
提供了快速入门，以演示在 JBoss EAP 上使用 Fuse 来制作和使用 JMS 消息的 camel-jms 组件。
在此快速入门中，Camel 路由会使用来自 EAP_HOME/standalone/data/orders 的文件，并将其内容放在名为 OrdersQueue 的内存中 ActiveMQ root 队列上。然后，另一个 Camel 路由消耗 OrdersQueue 的内容，并将订单排序为 EAP_HOME/standalone/data/orders/processed 中的各个国家目录。
CLI 命令创建和删除 OrdersQueue CLI 脚本，以便在部署应用和取消部署时为您创建并移除 JMS OrdersQueue。这些脚本位于 EAP_HOME/quickstarts/camel-jms/src/main/resources/cli 目录中。
先决条件
要运行此快速入门，您必须有一个 Fuse 7.11 工作版本
您还需遵循 使用 JBoss AMQ 进行远程 JMS 通信 中的说明，以连接到外部 AMQ 7 代理。然后您可以使用默认连接工厂注入连接工厂。
@Resource(mappedName = "java:jboss/RemoteJmsXA") ConnectionFactory connectionFactory;
@Resource(mappedName = "java:jboss/RemoteJmsXA")
ConnectionFactory connectionFactory;设置快速入门
- 以单机模式启动 JBOSS EAP。
-
导航到
EAP_HOME/quickstarts/camel/camel-jms -
输入
mvn clean install -Pdeploy'以构建和部署 Quickstart。 - 浏览至 http://localhost:8080/example-camel-jms
您应该会看到一个名为"Orders Received"的页面。随着向示例应用程序发送订单，在此页中将列出每个国家每个国家的订单列表。
运行快速入门
EAP_HOME/quickstarts/camel-jms/src/main/resources 目录中有一些示例顺序 XML 文件。Camel 将每 5 秒随机选择一个文件，并将其复制到 EAP_HOME/standalone/data/orders 中进行处理。
控制台将输出信息详细描述了每个订购所发生的情况。输出将如下所示：
JmsConsumer[OrdersQueue]) Sending order to the UK JmsConsumer[OrdersQueue]) Sending order to another country JmsConsumer[OrdersQueue]) Sending order to the US
JmsConsumer[OrdersQueue]) Sending order to the UK
JmsConsumer[OrdersQueue]) Sending order to another country
JmsConsumer[OrdersQueue]) Sending order to the US当文件被使用后，您可以返回到 http://localhost:8080/example-camel-jms/orders。每个国家的接收订单的数目应该已由 1 增加。
所有处理的订购将分成以下目的地：
EAP_HOME/standalone/data/orders/processed/uk EAP_HOME/standalone/data/orders/processed/us EAP_HOME/standalone/data/orders/processed/other
EAP_HOME/standalone/data/orders/processed/uk
EAP_HOME/standalone/data/orders/processed/us
EAP_HOME/standalone/data/orders/processed/other取消部署
要取消部署示例，可导航到 EAP_HOME/quickstarts/camel/camel-jms run mvn clean -Pdeploy。
'%20d='M201.5%20305.5c-13.8%200-24.9-11.1-24.9-24.6%200-13.8%2011.1-24.9%2024.9-24.9%2013.6%200%2024.6%2011.1%2024.6%2024.9%200%2013.6-11.1%2024.6-24.6%2024.6zM504%20256c0%20137-111%20248-248%20248S8%20393%208%20256%20119%208%20256%208s248%20111%20248%20248zm-132.3-41.2c-9.4%200-17.7%203.9-23.8%2010-22.4-15.5-52.6-25.5-86.1-26.6l17.4-78.3%2055.4%2012.5c0%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.3%2024.9-24.9s-11.1-24.9-24.9-24.9c-9.7%200-18%205.8-22.1%2013.8l-61.2-13.6c-3-.8-6.1%201.4-6.9%204.4l-19.1%2086.4c-33.2%201.4-63.1%2011.3-85.5%2026.8-6.1-6.4-14.7-10.2-24.1-10.2-34.9%200-46.3%2046.9-14.4%2062.8-1.1%205-1.7%2010.2-1.7%2015.5%200%2052.6%2059.2%2095.2%20132%2095.2%2073.1%200%20132.3-42.6%20132.3-95.2%200-5.3-.6-10.8-1.9-15.8%2031.3-16%2019.8-62.5-14.9-62.5zM302.8%20331c-18.2%2018.2-76.1%2017.9-93.6%200-2.2-2.2-6.1-2.2-8.3%200-2.5%202.5-2.5%206.4%200%208.6%2022.8%2022.8%2087.3%2022.8%20110.2%200%202.5-2.2%202.5-6.1%200-8.6-2.2-2.2-6.1-2.2-8.3%200zm7.7-75c-13.6%200-24.6%2011.1-24.6%2024.9%200%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.1%2024.9-24.6%200-13.8-11-24.9-24.9-24.9z'/%3e%3c/svg%3e){kind=small}