常に実行中のプロセスでカーマイン ワーカーを実装しようとしています。
次のアプリをlein run myclass.fooで起動すると、ワーカーを起動してすぐに停止します。
(def my-worker
(car-mq/worker queue-server "my-queue"
{:handler (fn [{:keys [message attempt]}]
(println "Received" message)
{:status :success})
:auto-start false}))
(defn -main []
(car-mq/start my-worker))
私の目標はそのようなものです
- foo リスナーを起動する
- foo リスナーはフォアグラウンドで実行され、キューにポストされるすべてのものを出力します
- Ctrl-c / quit はリスナーを閉じます