Я полагаю, что мне не хватает чего-то связанного с концепцией dds. Моя идея состоит в том, чтобы использовать адаптер EsperIO, поток данных или подключаемый модуль для вставки входящих событий из dds в механизм esper, но я не вижу этого ясно.
Кто-нибудь помогите!! (Заранее спасибо)
Шаг за шагом будет 1) получать данные о событиях от DDS, то есть Java DataReader 2) создать объект события, понятный Эсперу; для этого используйте, например, класс в стиле JavaBean 3) отправить объект события в Esper
Нет необходимости собирать адаптер или использовать EsperIO. API для передачи событий в Esper действительно прост. Код API см. В документации http://www.espertech.com/esper/longer-case-study/ или Esper.
Это для всех. Реализован ли какой-нибудь пример ??
Примеры являются частью zip- или jar-файла Esper, который вы можете скачать.
Большое спасибо, мы собираемся разработать Java API для этой цели.
Большое спасибо, я собираюсь попробовать ваше решение и прокомментировать отзыв.