     (check-fn)
     (check-fn)
     (.close s)))
-
-(deftest send-receive-with-the-same-session-should-work
-  (with-open [s (.createSession (.defaultConnection default) nil)]
-    (let [q (create-queue "send-receive-session")]
-      (.send q "success" "text/plain" (coerce-send-options {:session s}))
-      (is (= "success"
-            (.body (.receive q (coerce-receive-options {:session s}))
-              String))))))
 
 (deftest listen-should-use-the-passed-connection
   (let [c (.createConnection default nil)

                                                     :timeout 1000}))]
        (is msg)
        (is (= "success" (.body msg String)))))))

    (onMessage [_ m _]
      (f (.body m String)))))

(defn create-queue [& opts]
  (let [[name opts] opts
        name (or name (str (java.util.UUID/randomUUID)))]
    (.findOrCreateQueue default name
      (coerce-queue-options (merge opts {:durable false})))))

(defn create-topic [name]
  (.findOrCreateTopic default name nil))
