diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-01-18 12:20:21 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-01-18 12:20:21 +0000 |
| commit | cc8b0b5d752b2e16a92dede65af4c3bd5fc4a351 (patch) | |
| tree | a6c49684c3d29b554b2aa4a4740b755f3471c6c5 | |
| parent | 1d43ea4a18f534329161934af1d380ce5fcd94bc (diff) | |
| download | rabbitmq-server-git-cc8b0b5d752b2e16a92dede65af4c3bd5fc4a351.tar.gz | |
Correct comment and use spawn_link
| -rw-r--r-- | src/rabbit_tests.erl | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 7205a99f0d..96acbd9b51 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -2224,20 +2224,21 @@ test_amqqueue(Durable) -> with_fresh_variable_queue(Fun) -> Ref = make_ref(), Me = self(), - %% Run in a separate process since rabbit_variable_queue will send + %% Run in a separate process since rabbit_msg_store will send %% bump_credit messages and we want to ignore them - spawn(fun() -> - ok = empty_test_queue(), - VQ = variable_queue_init(test_amqqueue(true), false), - S0 = rabbit_variable_queue:status(VQ), - assert_props(S0, [{q1, 0}, {q2, 0}, - {delta, {delta, undefined, 0, undefined}}, - {q3, 0}, {q4, 0}, - {len, 0}]), - _ = rabbit_variable_queue:delete_and_terminate( + spawn_link(fun() -> + ok = empty_test_queue(), + VQ = variable_queue_init(test_amqqueue(true), false), + S0 = rabbit_variable_queue:status(VQ), + assert_props(S0, [{q1, 0}, {q2, 0}, + {delta, + {delta, undefined, 0, undefined}}, + {q3, 0}, {q4, 0}, + {len, 0}]), + _ = rabbit_variable_queue:delete_and_terminate( shutdown, Fun(VQ)), - Me ! Ref - end), + Me ! Ref + end), receive Ref -> ok end, |