如何将Jboss Fuse连接到数据库？

Question

我想直接将数据库连接到Fuse。我的目标是将一个或多个主题收到的所有消息保存在数据库（MySQL，postgreSQL，MongoDB，...）中。

我不需要故障转移数据库，基本上我会“订阅”数据库，以主题，并保存所有消息供日后分析。

什么是做到这一点的最简单的方法？

Answer 1

在高层次上，最容易做的事情是设置一个Camel路由，使用JMS组件（或者如果您使用的是代理使用ActiveMQ）从主题中消耗，然后将消息正文写入使用JDBC组件的数据库。您可以使用PID来控制所消耗的主题（或主题）。

要创建JDBC连接，您可以将其设置为包含骆驼路径（通过蓝图/弹簧）的bundle的一部分，或者可以创建一个单独的包，通过蓝图/ spring创建JDBC连接/数据源，以及然后将其作为骆驼路线的OSGi服务公开。