1

我有一个场景，其中我有 MQTT 发布者。

MQTT 客户端 --> 消息代理 --> WSO2 CEP（JMS 输入适配器）

我可以通过哪些方式将此已发布的 MQTT 消息作为 WSO2 CEP 的输入？

我尝试使用 ActiveMQ 作为消息代理和 CEP JMS 输入适配器来侦听 JMS 消息，但 ActiveMQ 将 MQTT 消息转换为 ByteMessage，我相信 CEP 目前还没有处理它，因为在同一设置中发布的 JMS 消息工作正常。
我知道 WSO2 CEP 4.0.0 具有 MQTT 输入适配器的功能。如何在 CEP 3.1.0 中处理它？

4

2 回答 2

4

是的，我们还没有处理 CEP 3.1.0 中 JMS 输入事件适配器的 ByteMessage 场景。但是，我们已经在 CEP 4.0.0 中修复了这个问题（以及在 BAM 2.5.0 中发布的 CEP 功能）

我喜欢提供一些选项以使其与 CEP 3.1.0 一起使用。正如 Tharik 提到的，MQTT 输入事件适配器功能可从下一个 CEP 版本（4.0.0）中获得。以下是可能的选项。

1) 您可以修补 JMS 输入事件适配器并将其作为 CEP 服务器的修补程序包含在内。（修复在 [1] 中可用）

2) 使用 BAM 2.5.0 中可用的 MQTT 输入事件适配器 jar。（构建源[2]并将jar复制到CEP的dropins文件夹并遵循[3]）

3) 编写您自己的自定义 MQTT 输入事件适配器，如 [4] 中给出的

[1] https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/components/event-stream/event-input-adaptor/org.wso2.carbon.event.input.adaptor.jms /1.0.2/src/main/java/org/wso2/carbon/event/input/adaptor/jms/internal/util/JMSMessageListener.java

[2] https://svn.wso2.org/repos/wso2/carbon/platform/branches/turing/components/event-stream/event-input-adaptor/org.wso2.carbon.event.input.adaptor.mqtt /1.0.0

[3] https://docs.wso2.com/display/BAM250/Input+MQTT+Event+Adapter

[4] https://mohanadarshan.wordpress.com/2014/07/14/writing-custom-event-adaptors-in-wso2-cep-3-1-0/

谢谢..

于 2015-06-14T11:59:36.330 回答
2

正如您提到的，WSO2 CEP 从 4.0.0 版本开始支持 MQTT。您无法将 WSO2 CEP 4.0.0 MQTT 组件/功能添加到 CEP 3.1.0，因为新版本中的输入适配器架构不同。

我强烈推荐使用 CEP 4.0.0。如果您真的希望在 CEP 3.1.0 中使用此功能，则必须为 CEP 3.1.0 编写自定义事件适配器。您可以使用参考新版本源来获得一些想法，但适配器实现是不同的。

于 2015-06-12T11:24:45.177 回答