Account for the new default concurrency.

Messages can now be handled out of order, since there is more than one listener.
immutant · Apr 10, 2015 · d3fbf94 · d3fbf94
1 parent 02fb891
commit d3fbf94
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/integration-tests/test-clustering/integs/cluster_test.clj b/integration-tests/test-clustering/integs/cluster_test.clj
@@ -80,7 +80,7 @@
               ctx2 (msg/context (assoc opts :port (http-port "server-two")))]
     (let [q1 (msg/queue "/queue/cluster" :context ctx1)
           q2 (msg/queue "/queue/cluster" :context ctx2)
-          received (atom [])
+          received (atom #{})
           p (promise)
           c 100]
       (msg/listen q2 (fn [m]
@@ -91,4 +91,4 @@
       (dotimes [i c]
         (msg/publish q1 i))
       (deref p 60000 nil)
-      (is (= (range c) @received)))))
+      (is (= (set (range c)) @received)))))