   (is (= "kiwi" (:name (read-thing-from-db {:datasource db} "kiwi"))))
   (is (= 1 (count-things-in-db {:datasource db})))
   (is (= "kiwi" (imsg/receive "/queue/test")))
+  (is (= "starfruit" (imsg/receive "/queue/remote-test")))
   (is (= 1 (:a cache))))
 
 (defn verify-transaction-failure [db]
   (is (nil? (read-thing-from-db {:datasource db} "kiwi")))
   (is (= 0 (count-things-in-db {:datasource db})))
   (is (nil? (:a cache)))
-  (is (nil? (imsg/receive "/queue/test" :timeout 2000))))
+  (is (nil? (imsg/receive "/queue/test" :timeout 2000)))
+  (is (nil? (imsg/receive "/queue/remote-test" :timeout 2000))))
 
 (defn define-tests [db]
   (eval `(let [ds# (var-get (resolve (symbol ~db)))]


;;; Create a JMS queue
(imsg/start "/queue/test")

;;; And an Infinispan cache
(def cache (ic/cache "test"))

    (apply use-fixtures :each cache-fixture (map #(db-fixture (var-get (resolve (symbol %)))) dbs))
    (doseq [db dbs]
      (define-tests db))
    (run-tests)))
