【发布时间】:2011-05-23 05:03:51
【问题描述】:
我想编写一个修改过的 ActiveMQ 代理,当他侦听特定主题的 producers' 消息以交替处理它们时(例如使用 HDFS API,而不使用默认持久存储)。你有什么想法从哪里开始吗?
提前致谢, 佩鲁奇
【问题讨论】:
我想编写一个修改过的 ActiveMQ 代理,当他侦听特定主题的 producers' 消息以交替处理它们时(例如使用 HDFS API,而不使用默认持久存储)。你有什么想法从哪里开始吗?
提前致谢, 佩鲁奇
【问题讨论】:
您可以为 HDFS 实现自己的 ActiveMQ message store,这将允许 ActiveMQ 将 HDFS 用作持久性存储,或者您可以创建一个 ActiveMQ broker plugin,允许您在消息进入代理时拦截它们。两者都是非常不同的方法,因此这实际上取决于您对采用哪条路径的要求。
布鲁斯
【讨论】: