1

常に実行中のプロセスでカーマイン ワーカーを実装しようとしています。

次のアプリを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 はリスナーを閉じます
4

1 に答える 1