   (start "server-one")
   (is (= :pong (get-as-data "/ping" "server-one"))))
 
-(deftest session-replication
+(marktest session-replication
   (is (= 0 (get-as-data "/counter" "server-one")))
   (is (= 1 (get-as-data "/counter" "server-two")))
   (is (= 2 (get-as-data "/counter" "server-one")))

    ;; across restarts
    (is (apply < (map :count @responses)))))

(deftest publish-here-receive-there
  (with-open [ctx1 (msg/context (assoc opts :port (http-port "server-one")))
              ctx2 (msg/context (assoc opts :port (http-port "server-two")))]
    (let [q1 (msg/queue "/queue/cluster" :context ctx1)

  (start "server-one")
  (is (= 4 (get-as-data "/counter" "server-one"))))

(marktest failover
  (let [responses (atom [])
        response (fn [s]
                   (with-open [c (msg/context (assoc opts :port (http-port s)))]
