我想使用 Clojure 从队列中连接和消费。我不知道哪个是该任务的最佳 clojure API (Storm-JMS??)。
有人知道哪个 API 是最好的吗?也许你有一个例子说明 Clojure 中的消费是如何完成的?
我的最终目标是使用 clojure 宏defspout编写一个storm spout ,并使用队列中的元组。
任何帮助,将不胜感激!
问候,贺拉斯
我想使用 Clojure 从队列中连接和消费。我不知道哪个是该任务的最佳 clojure API (Storm-JMS??)。
有人知道哪个 API 是最好的吗?也许你有一个例子说明 Clojure 中的消费是如何完成的?
我的最终目标是使用 clojure 宏defspout编写一个storm spout ,并使用队列中的元组。
任何帮助,将不胜感激!
问候,贺拉斯
为了让你开始使用 Storm,在 github 上为你准备了一个字数统计示例项目:
https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm
依赖项都在 project.clj 文件中并且开箱即用。
虽然,为了确保,Storm 正在处理并且可以与外部排队系统集成。如果您只需要使用排队系统,请查看以下示例: