summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-22 12:50:35 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-22 12:50:35 +0000
commit83dbfae2a2140c60b45b46dd29a215be3a85db6e (patch)
tree853a0e9aaa419156f406ad132d1bed3fefc6e835
parentf06a87a2d54456fd8953315b1c4c8a24656c0d6c (diff)
parentc408184ffd653dc7b52fe584b9e13f410229e142 (diff)
downloadrabbitmq-server-83dbfae2a2140c60b45b46dd29a215be3a85db6e.tar.gz
merge bug25360 into stable
-rw-r--r--src/rabbit_tests.erl9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl
index a68caadb..7a0ed1af 100644
--- a/src/rabbit_tests.erl
+++ b/src/rabbit_tests.erl
@@ -1084,9 +1084,16 @@ test_policy_validation() ->
rabbit_runtime_parameters_test:unregister_policy_validator(),
passed.
+writer() ->
+ receive
+ {'$gen_call', From, flush} -> gen_server:reply(From, ok),
+ writer();
+ shutdown -> ok
+ end.
+
test_server_status() ->
%% create a few things so there is some useful information to list
- Writer = spawn(fun () -> receive shutdown -> ok end end),
+ Writer = spawn(fun writer/0),
{ok, Ch} = rabbit_channel:start_link(
1, self(), Writer, self(), "", rabbit_framing_amqp_0_9_1,
user(<<"user">>), <<"/">>, [], self(),