pipe.clj

(let [[message-seq put] (pipe)]
  (letfn [(message-handler [ch msg-meta payload])
            (put {:ch ch :msg-meta msg-meta :payload payload})]
    (lc/subscribe ch qname message-handler :auto-ack true))
  message-seq)

(let [[message-seq put] (pipe)]
  (letfn [(message-handler [ch msg-meta payload]
            (put {:ch ch :msg-meta msg-meta :payload payload}))]
    (lc/subscribe ch qname message-handler :auto-ack true))
  message-seq)