Clojure を使用してキューから接続して消費したいと考えています。そのタスクに最適な clojure API (Storm-JMS??) がどれかわかりません。
誰かがどの API が最適か知っていますか? Clojure で消費がどのように行われるかの例をお持ちですか?
私の最終的な目標は、clojure マクロdefspoutを使用してストーム スパウトを作成し、キューからタプルを消費することです。
どんな助けでも大歓迎です!
よろしく、ホレス
Clojure を使用してキューから接続して消費したいと考えています。そのタスクに最適な clojure API (Storm-JMS??) がどれかわかりません。
誰かがどの API が最適か知っていますか? Clojure で消費がどのように行われるかの例をお持ちですか?
私の最終的な目標は、clojure マクロdefspoutを使用してストーム スパウトを作成し、キューからタプルを消費することです。
どんな助けでも大歓迎です!
よろしく、ホレス
ストームを使い始めるために、github に用意されているワード カウントのサンプルプロジェクトがあります。
https://github.com/denno-clojure/mascarpone/tree/master/chapter05_storm
依存関係はすべて project.clj ファイルにあり、すぐに実行できます。
ただし、念のために言っておきますが、Storm が処理を行っており、外部のキュー システムと統合できます。単にキューイング システムを使用する必要がある場合は、次のサンプルのいくつかを見てください。