diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-07-26 14:09:33 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-07-26 14:09:33 +0100 |
| commit | 81e28d508e8fe0414f523b5f02f3cfd00e3e7899 (patch) | |
| tree | b8c9291851c6eba3984cbeebbbb083ebacb6ae42 | |
| parent | 4f9b1e18de0882229ffea44e2783177c60a666f2 (diff) | |
| download | rabbitmq-server-81e28d508e8fe0414f523b5f02f3cfd00e3e7899.tar.gz | |
More consistent use of macro
| -rw-r--r-- | src/rabbit_backing_queue_qc.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_backing_queue_qc.erl b/src/rabbit_backing_queue_qc.erl index e372e351..e20bba07 100644 --- a/src/rabbit_backing_queue_qc.erl +++ b/src/rabbit_backing_queue_qc.erl @@ -73,7 +73,7 @@ backing_queue_test(Cmds) -> application:set_env(rabbit, queue_index_max_journal_entries, MaxJournal, infinity), - rabbit_variable_queue:delete_and_terminate(shutdown, BQ), + ?BQMOD:delete_and_terminate(shutdown, BQ), ?WHENFAIL( io:format("Result: ~p~n", [Res]), aggregate(command_names(Cmds), Res =:= ok)). @@ -329,9 +329,9 @@ publish_multiple(Msg, MsgProps, BQ, Count) -> timeout(BQ, 0) -> BQ; timeout(BQ, AtMost) -> - case rabbit_variable_queue:needs_timeout(BQ) of + case ?BQMOD:needs_timeout(BQ) of false -> BQ; - _ -> timeout(rabbit_variable_queue:timeout(BQ), AtMost - 1) + _ -> timeout(?BQMOD:timeout(BQ), AtMost - 1) end. qc_message_payload() -> |