У нас есть приложение, предоставленное третьей стороной, которое принимает поток рыночных данных (предоставленных указанной третьей стороной) и записывает их в JDBC-совместимую базу данных.
Единственные параметры конфигурации, которые он имеет, - это строка подключения JDBC, плюс настройки, позволяющие нам выбирать, какие части данных мы хотели бы сохранить в этой базе данных.
Это очень хорошо для статических данных, но мы хотели бы передать эти данные во внутреннюю структуру обмена сообщениями ActiveMQ (в дополнение к записи в БД).
Обновления базы данных инициируются посылкой нам рыночных данных. Я бы хотел, чтобы это приложение записывало данные непосредственно в набор тем MQ, реализуя некий «фасад» jdbc, который перенаправлял бы данные прямо в MQ.
Чего я не хочу делать, так это опрашивать базу данных на предмет новой информации - поскольку я хочу сохранить ту же самую текучесть данных (например, быстро движущиеся акции будут генерировать намного больше данных, чем медленно движущиеся), и мы бы хотели сохранить это).
Советы и указатели приветствуются!