【发布时间】:2015-05-09 13:18:34
【问题描述】:
我想直接将数据库连接到 Fuse。我的目标是将一个或多个主题收到的所有消息保存在数据库(MySQL、postgreSQL、MongoDB ......)中。
我不需要故障转移数据库,基本上我会“订阅”一个数据库到主题并保存所有消息以供将来分析。
最简单的方法是什么?
【问题讨论】:
标签: mongodb postgresql jboss jbossfuse database
我想直接将数据库连接到 Fuse。我的目标是将一个或多个主题收到的所有消息保存在数据库(MySQL、postgreSQL、MongoDB ......)中。
我不需要故障转移数据库,基本上我会“订阅”一个数据库到主题并保存所有消息以供将来分析。
最简单的方法是什么?
【问题讨论】:
标签: mongodb postgresql jboss jbossfuse database
在高层次上,最简单的做法是设置一个 Camel 路由,该路由使用 JMS 组件(或 ActiveMQ,如果您将其用于代理)从主题中消费,然后将消息正文写入使用 JDBC 组件的数据库。您可以使用 PID 来控制所使用的主题(或多个主题)。
要创建 JDBC 连接,您可以将其设置为包含 Camel Route(通过 blueprint/spring)的捆绑包的一部分,或者您可以创建一个单独的捆绑包,通过 blueprint/spring 创建 JDBC 连接/数据源,然后将其公开为骆驼路线的 OSGi 服务。
【讨论】: