diff options
| -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 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 |