我相信我错过了与 dds 概念相关的东西。我的想法是使用 EsperIO 适配器、数据流或插件将来自 dds 的传入事件插入到 esper 引擎,但我看不清楚。
有人帮忙!!(提前致谢)
我相信我错过了与 dds 概念相关的东西。我的想法是使用 EsperIO 适配器、数据流或插件将来自 dds 的传入事件插入到 esper 引擎,但我看不清楚。
有人帮忙!!(提前致谢)
一步一步是 1) 从 DDS 即 Java DataReader 接收事件数据 2) 构建一个 Esper 可以理解的事件对象;为此,请使用 JavaBean 样式的类,例如 3) 将事件对象发送到 Esper
无需构建适配器或使用 EsperIO。将事件输入 Esper 的 API 非常简单。有关 API 代码,请参阅http://www.espertech.com/esper/longer-case-study/或 Esper 文档。