Clojure & ActiveMQ & Storm: потреблять из очереди используя clojure

Question

Я хотел бы подключиться и потреблять из очереди с помощью Clojure. Я не знаю, какой лучший API-интерфейс clojure (Storm-JMS ??) для этой задачи.

Кто-нибудь знает, какой API лучше? Возможно, у вас есть пример того, как потребление происходит в Clojure?

Моя конечная цель - написать штормовой носик, используя макрос clojure defspout и потреблять кортежи из очереди.

Любая помощь будет оценена!

С уважением, Горация

Answer 1

В дополнение к Nicolas Modrzyk: Langohr очень хороший Clojure API для RabbitMQ, который хорошо сочетается со Storm.

Answer 2

Чтобы вы начали с бурей, есть word count example проект готов для вас на GitHub:

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

Зависимости все в файле project.clj и выбегает из коробки.

Хотя, чтобы убедиться, что Шторм выполняет обработку и может integrate with external queueing systems. Если вам просто нужно использовать систему массового обслуживания, рассмотрим некоторые из следующих образцов:

• Clojure with ActiveMQ
• Redis publisher и Redis subscriber