summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2012-04-02 17:59:05 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2012-04-02 17:59:05 +0100
commita5daf98affc83337b5d19a989048cb544861f007 (patch)
tree577ca93e4c438eb2450b3dd7abcaca638e4b3d95
parent31a2d05d01096c7821587dcbe8eb54c62152c9f2 (diff)
downloadrabbitmq-server-bug24843.tar.gz
fix a racebug24843
-rw-r--r--src/rabbit_tests.erl3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl
index 9cb830e9..e356d7ff 100644
--- a/src/rabbit_tests.erl
+++ b/src/rabbit_tests.erl
@@ -1245,6 +1245,9 @@ test_confirms() ->
},
rabbit_basic:build_content(
#'P_basic'{delivery_mode = 2}, <<"">>)),
+ %% We must not kill the queue before the channel has processed the
+ %% 'publish'.
+ ok = rabbit_channel:flush(Ch),
%% Crash the queue
QPid1 ! boom,
%% Wait for a nack