diff options
| -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, |