 (defn message-handler
   [ch {:keys [content-type delivery-tag type] :as meta} ^bytes payload]
   (do
-    (println (format "[consumer] Received a message: %s, delivery tag: %d, content type: %s, type: %s"
-                     (String. payload "UTF-8") delivery-tag content-type type))
+    (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

            [langohr.channel   :as lch]
            [langohr.queue     :as lq]
            [langohr.consumers :as lc]
            [langohr.basic     :as lb]))

(def ^{:const true}
  exchange-name "")

  [& args]
  (let [[options args banner]
        (cli args
          ["-h" "--help" "Show help" :default false :flag true]
          ["-n" "--nworkers" "The amount of worker threads to start" :default (.availableProcessors (Runtime/getRuntime)) :parse-fn #(Integer. %)]
          ["-m" "--method" "The R method and queue name to execute" :default "echo"])
        conn (rmq/connect)
        qname (format "task.%s" (:method options))]
    (when (or (:help options))
