Esper CEP引擎如何连接DDS
How to connect Esper CEP engine with DDS
我相信我遗漏了与 dds 概念相关的内容。我的想法是使用EsperIO适配器，数据流或插件将来自dds的incomming事件插入esper引擎，但我看不清楚。
有人帮忙！！ （提前致谢）
一步一步是
1) 从 DDS 接收事件数据，即 Java DataReader
2）构建一个Esper可以理解的事件对象；例如，为此使用 JavaBean 样式 class
3) 将事件对象发送到 Esper
无需构建适配器或使用 EsperIO。 API 将事件输入 Esper 非常简单。对于 API 代码，请参阅 http://www.espertech.com/esper/longer-case-study/ 或 Esper 文档。
我相信我遗漏了与 dds 概念相关的内容。我的想法是使用EsperIO适配器，数据流或插件将来自dds的incomming事件插入esper引擎，但我看不清楚。
有人帮忙！！ （提前致谢）
一步一步是 1) 从 DDS 接收事件数据，即 Java DataReader 2）构建一个Esper可以理解的事件对象；例如，为此使用 JavaBean 样式 class 3) 将事件对象发送到 Esper
无需构建适配器或使用 EsperIO。 API 将事件输入 Esper 非常简单。对于 API 代码，请参阅 http://www.espertech.com/esper/longer-case-study/ 或 Esper 文档。