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

   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))

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