Work-in-progress wrapper around langohr - Clojure RabbitMQ client library

example.clj

(ns something.core
  (:require [something.message-bus :as message-bus]))

; handler simply gets a hashmap, from the JSON payload
; Responses are modeled after jondot/sneakers
; :ack - acks
; :reject - rejects message, it will be retiried
; :reject-requeue - rejects and requeues straight away (dangerous!)
(defn handler-fn [payload]
  (let [m (:m payload)]
    (if
      (= m 6)
      { :status :ack }
      { :status :reject })))

(defn -main []
  (message-bus/start  handler-fn
                     { :queue-name "some.queue"
                      :message-ttl 60000
                     :max-retries 5}))