                      :reply-text reply-text
                      :exchange exchange
                      :routing-key routing-key
-                     :body (-> (Base64/getEncoder) (.encodeToString body))}))))))
+                     :body  (.encodeToString (Base64/getEncoder) body)}))))))
 
 (defn ->reliable-chan
   "Return an implementation of the the ReliablePublish protocol."

  [confirmation-chan]
  (reify ReturnListener
    (handleReturn [_ reply-code reply-text exchange routing-key properties body]
      (let [headers (-> properties (.getHeaders))]
        (a/>!! confirmation-chan (->Confirm (get headers (str ::delivery-tag))
                                            false
                                            :failure))

  "Listen for Confirm messages.

   A message is Ack'd once the broker routes the message or determines
  the message is unroutable.

   A message is Nack'd when the broker encounters an
  exception (eg. out of memory or a disk failure) while trying to
  route the message."
  [confirmation-chan]
