0

我想使用 Clojure 从队列中连接和消费。我不知道哪个是该任务的最佳 clojure API (Storm-JMS??)。

有人知道哪个 API 是最好的吗?也许你有一个例子说明 Clojure 中的消费是如何完成的?

我的最终目标是使用 clojure 宏defspout编写一个storm spout ,并使用队列中的元组。

任何帮助,将不胜感激!

问候,贺拉斯

4

2 回答 2

0

为了让你开始使用 Storm,在 github 上为你准备了一个字数统计示例项目:

https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm

依赖项都在 project.clj 文件中并且开箱即用。

虽然,为了确保,Storm 正在处理并且可以与外部排队系统集成。如果您只需要使用排队系统,请查看以下示例:

于 2013-10-25T01:32:27.307 回答
0

补充 Nicolas Modrzyk:Langohr是一个非常好的用于RabbitMQ的 Clojure API ,它与 Storm 很好地集成。

于 2013-11-07T21:01:06.757 回答