 (comment
   (let [conn (rmq/connect)
         ch (lch/open conn)]
-    (lb/publish ch "" queue-name "Hi!" {:content-type "text/plain" :type "index-concept"}))
+    (lb/publish ch exchange-name queue-name "Hi!" {:routing-key queue-name :content-type "text/plain" :type "index-concept"}))
 
 
   )

  [num-channels]
  (let [conn (rmq/connect)
        channels (doall (for [_ (range num-channels)]
                          (lch/open conn)))]

    (->MessageConsumer conn channels false)))


  ;; prevents this.
  (lb/qos ch 1)
  (lq/declare ch queue-name {:exclusive false :auto-delete false})
  (lq/bind ch queue-name exchange-name {:routing-key queue-name})
  (lc/subscribe ch queue-name message-handler {:auto-ack false}))

(defrecord MessageConsumer
  [
