summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-08-16 12:29:44 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-08-16 12:29:44 +0100
commit1f4ab1c7b1192d4999bb2293b4b6e06919cf4e0e (patch)
treeebfbeadc0ec84a87a458162549dd7dcd12794f81
parentad9abe5c9106d468bcc369118bcf69dfb8815f14 (diff)
downloadrabbitmq-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.erl8
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) ->