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

                     :reply-text reply-text
                     :exchange exchange
                     :routing-key routing-key
                     :body (-> (Base64/getEncoder) (.encodeToString body))}))))))

(defn ->reliable-chan
  "Return an implementation of the the ReliablePublish protocol."

  "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]
