             [langohr.channel   :as lch]
             [langohr.queue     :as lq]
             [langohr.consumers :as lc]
-            [langohr.basic     :as lb]))
+            [langohr.basic     :as lb]
+            [clojure.tools.logging :as log]))
 
 (def ^{:const true}
   exchange-name "")

      (System/exit 0))
    (dotimes [n (:nworkers options)]
      (let [ch (lch/open conn)]
        (println (format "[main] Connected worker %d. Channeld id: %d for channel %s" n (.getChannelNumber ch) qname))
        (lq/declare ch qname :exclusive false :auto-delete true)
        (start-consumer conn ch qname)))
      (while true (Thread/sleep 100))

(defn message-handler
  [ch {:keys [content-type delivery-tag type] :as meta} ^bytes payload]
  (do
    (log/debug
      (format "[consumer] Received a message: %s, delivery tag: %d, content type: %s, type: %s"
        (String. payload "UTF-8") delivery-tag content-type type))
    (Thread/sleep 2000)))

(defn start-consumer
