         (.setMessageListener (consumer-fn session)
           (create-listener handler))))
     (.start connection)
-    connection
+    [connection (destination-name dest)]
     (catch Throwable e
       (close-connection connection)
       (throw e))))

   call. The deref will resolve to a boolean that is true if there was
   actually something to unlisten, false otherwise."
  [listener]
  (when-let [group (maybe-deref listener)]
    (future
      (if (or (instance? java.io.Closeable group)
              (instance? javax.jms.Connection group))

                     {:keys [izer connection listener-name setup-fn]}
                     {:keys [concurrency] :as opts}]
  (log/info "Creating in-vm listener for:" dest)
  (let [dest-name (destination-name dest)
        group (.createGroup
                izer
                dest-name
                false ;; TODO: singleton
                concurrency
                (not (nil? (:client-id opts)))
