better.clj

(defn subscriber-seq
  [ch qname]
  (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))

(defn payload-str
  [x]
  (String. payload "UTF-8")
 
(map (comp read-json payload-str :payload)
     (subscriber-seq ch qname))