diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_tests.erl | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index cf477a16eb..f36b21ca7e 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -1578,17 +1578,19 @@ test_queue_cleanup(_SecondaryNode) -> ok after 1000 -> throw(failed_to_receive_queue_declare_ok) end, + rabbit_channel:shutdown(Ch), rabbit:stop(), rabbit:start(), - rabbit_channel:do(Ch, #'queue.declare'{ passive = true, - queue = ?CLEANUP_QUEUE_NAME }), + {_Writer2, Ch2} = test_spawn(), + rabbit_channel:do(Ch2, #'queue.declare'{ passive = true, + queue = ?CLEANUP_QUEUE_NAME }), receive #'channel.close'{reply_code = ?NOT_FOUND} -> ok after 2000 -> throw(failed_to_receive_channel_exit) end, - rabbit_channel:shutdown(Ch), + rabbit_channel:shutdown(Ch2), passed. test_declare_on_dead_queue(SecondaryNode) -> |