Clojure＆ActiveMQ＆Storm：使用clojure从队列中消耗

Question

我想使用Clojure从队列中连接和使用。我不知道哪个是最适合该任务的clojure API（Storm-JMS ??）。

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

我的最终目标是使用clojure宏defspout编写一个风暴喷口，并消耗队列中的元组。

任何帮助，将不胜感激！

问候，贺拉斯

Answer 1

为了补充萨科Modrzyk：Langohr是一个非常好的Clojure的API为RabbitMQ，它与Storm很好地结合在一起。

Answer 2

为了让您一开始，有暴风雨，有word count example项目为你准备在GitHub上：

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

相关性都在project.clj文件，并运行了的盒子。

虽然，只是为了确认，Storm正在处理并可以integrate with external queueing systems。 如果你只需要使用一个排队系统，看看下面的一些样本：

• Clojure with ActiveMQ
• Redis publisher和Redis subscriber