diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-08-16 12:29:44 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-08-16 12:29:44 +0100 |
| commit | 1f4ab1c7b1192d4999bb2293b4b6e06919cf4e0e (patch) | |
| tree | ebfbeadc0ec84a87a458162549dd7dcd12794f81 | |
| parent | ad9abe5c9106d468bcc369118bcf69dfb8815f14 (diff) | |
| download | rabbitmq-server-git-1f4ab1c7b1192d4999bb2293b4b6e06919cf4e0e.tar.gz | |
I think this was the problem - since the channel was not part of the supervision hierarchy it would not get shut down (and if it was the test would not work!) but it could try to send stats when rabbit_event was down. So close and recreate the channel.
| -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) -> |
