   (:require [clojure.test :refer :all])
   (:import [org.projectodd.wunderboss Option WunderBoss]
            [org.projectodd.wunderboss.codecs Codecs None StringCodec]
-           [org.projectodd.wunderboss.messaging Messaging
+           [org.projectodd.wunderboss.messaging
+            Messaging
             Context Context$Mode
             ConcreteReply
             Destination Destination$ListenOption Destination$ReceiveOption

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

(deftest context-rollback

            Topic$SubscribeOption Topic$UnsubscribeOption
            Messaging$CreateContextOption Messaging$CreateQueueOption
            MessageHandler]
           java.util.concurrent.TimeUnit
           (javax.jms IllegalStateRuntimeException InvalidDestinationRuntimeException)
           (java.util.concurrent CountDownLatch TimeoutException)
           (java.util UUID)))

(def default (doto (WunderBoss/findOrCreateComponent Messaging) (.start)))

