在ActiveMQ Artemis中为MQTT处理设置和配置Apache Camel



我是ActiveMQ和Apache Camel的新手,对它们和Camel设置有一些问题。

我运行的是ActiveMQ Artemis 2.14.0(docker镜像(,端口1883上运行的是MQTT代理。

客户端1正在使用MQTT发布一些消息,而客户端2正在订阅并检索这些消息。现在,我想将Camel与ActiveMQ Artemis一起添加为控制器(路由器(,这样我就可以控制MQTT数据的转发或编辑它,还可以进行一些MQTT到REST的转换。

我不知道我需要使用ActiveMQ Artemis和Camel的哪些组件。

Camel已经在ActiveMQ Artemis中了吗?我需要在配置中添加一些东西来激活它吗?

如果是,那么我不知道我需要在ActiveMQ Artemis中的何处以及哪些配置文件进行编辑才能在其中设置Camel

当我在互联网上搜索时,我看到了很多Camel配置的Java和XML代码,但它们都有点混乱。这只是一堆拼图,我不知道该把什么拼图放在哪里。

Camel不附带ActiveMQ Artemis。配置Camel有两个基本选项。您可以下载它并独立于代理进行配置。或者,您可以将Camel路由放入web应用程序中,并将其部署到broker的嵌入式servlet contain(即Jetty(中;骆驼;ActiveMQ Artemis附带的示例(位于examples/features/standard/camel目录中(。

请注意,JMS组件的文档将指出,如果您使用的是ActiveMQ,则应该使用ActiveMQ组件。只有当您使用的是ActiveMQ 5.x而不是ActiveMQ Artemis时,这才有效。

此外,如果您想使用池连接工厂,您可以使用它,它是一个基于ActiveMQ 5.x JMS池连接工厂的独立项目。

相关内容

  • 没有找到相关文章

最新更新