Я хотел бы подключиться и использовать из очереди с помощью Clojure. Я не знаю, какой из clojure лучше всего подходит для этой задачи (Storm-JMS??).
Кто-нибудь знает, какой API лучше? Может быть, у вас есть пример того, как потребление выполняется в Clojure?
Моя конечная цель — написать штормовой носик с помощью макроса clojure defspout и использовать кортежи из очереди.
Любая помощь будет оценена по достоинству!
С уважением, Гораций
Чтобы начать работу со storm, существует ссылка пример подсчета слов готов для вас на github:
https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm
Все зависимости находятся в файле project.clj и запускаются из коробки.
Хотя, чтобы убедиться, что Storm выполняет обработку и может интегрироваться с внешними системами очередей . Если вам просто нужно использовать систему очередей, посмотрите на некоторые из следующих примеров:
