       (let [response (.request queue "nope" None/INSTANCE codecs nil)]
         (.await latch 10 TimeUnit/SECONDS)
         (Thread/sleep 100)
-        (is (thrown? java.util.concurrent.TimeoutException
+        (is (thrown? TimeoutException
               (.get response 1 TimeUnit/MILLISECONDS)))))))
 
 (deftest context-rollback


(deftest request-response-with-ttl
  (let [queue (create-queue "rr-queue")
        latch (java.util.concurrent.CountDownLatch. 1)]
    (with-open [listener (.respond queue
                           (handler (fn [m]
                                      (.countDown latch)


(deftest listen-with-concurrency
  (let [queue (create-queue "listen-queue")
        latch (CountDownLatch. 5)
        listener (.listen queue
                   (handler
                     (fn [msg]
