Vertx和Camel集成

Posted 2021-04-14

我正在试图弄清楚从Apache Camel路由向外部Vert.x事件总线发送消息的最佳方法。

我查看了camel-vertx库和vertx-camel-bridge，但是这些库似乎用于在同一个JVM中运行的Camel和Vert.x之间的通信，我没有看到Camel和Vert的任何示例。 x单独运行。

我的假设是否正确？ ActiveMQ会成为Vertx和Camel之间的良好桥梁吗？

答案

Vert.x事件总线可以群集。在一个节点（A）上，您可以使用纯Vert.x应用程序发送消息。在另一个节点（B）上，您可以将Camel应用程序与Vert.x Camel网桥连接。

在节点A上：

vertx.eventBus().send("eventbus-address", "a message");

在节点B上：

CamelContext camel = new DefaultCamelContext();
OutboundMapping outbound = OutboundMapping
  .fromVertx("eventbus-address")
  .toCamel("stream:out");
CamelBridge.create(vertx, new CamelBridgeOptions(camel)
  .addOutboundMapping(outbound)).start();