Я хотел бы напрямую подключить базу данных к Fuse. Моя цель - сохранить все сообщения, полученные одной или несколькими темами внутри базы данных (MySQL, postgreSQL, MongoDB, ...).Как подключить Jboss Fuse к базе данных?
Мне не нужна база данных с отказоустойчивостью, в основном я бы «подписал» базу данных на темы и сохранил все сообщения для будущего анализа.
Что это самый простой способ сделать это?
На более высоком уровне проще всего настроить маршрут Camel, который потребляет из темы с использованием компонента JMS (или ActiveMQ, если вы используете его для вашего брокера), а затем написать тело сообщения в базы данных с использованием компонента JDBC. Вы можете использовать PID для управления темой (или темами), которые потребляются.
Чтобы создать соединение JDBC, вы можете либо настроить это как часть вашего пакета, содержащего маршрут верблюжьей линии (по чертежу/пружине), либо создать отдельный пакет, который создает соединение/источник данных JDBC с помощью схемы/пружины и затем предоставляет его в качестве службы OSGi для верблюжьего маршрута.