diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-02 17:59:05 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-02 17:59:05 +0100 |
| commit | 873de93caeeb2c5cdba26de755b3e153242eb979 (patch) | |
| tree | 577ca93e4c438eb2450b3dd7abcaca638e4b3d95 /src | |
| parent | d262eaf822d1eac3c226a9cf28b1fc2098bc513c (diff) | |
| download | rabbitmq-server-git-873de93caeeb2c5cdba26de755b3e153242eb979.tar.gz | |
fix a race
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_tests.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 9cb830e914..e356d7ff8e 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 |