   [^javax.jms.XAConnection listener]
   (.close listener))
 
-(defn stop 
+(defn stop
   "Destroy a message destination. Typically not necessary since it
   will be done for you when your app is undeployed. This will fail
   with a warning if any handlers are listening"

               :selector (str "JMSCorrelationID='" (.getJMSMessageID message) "'"))))))

(defn respond
  "Listen for messages on queue sent by the request function and respond with the 
result of applying f to the message. queue can either be the name of the
queue or a javax.jms.Queue. Accepts the same options as listen."
  [queue f & {:keys [decode?] :or {decode? true} :as opts}]

  (:require [immutant.messaging.codecs :as codecs]
            [immutant.registry         :as reg]))

(defn start
  "Create a message destination; name should be prefixed with either /queue or /topic"
  [name & opts]
  (cond
