diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-07-06 14:41:47 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-07-06 14:41:47 +0100 |
| commit | c08f792cf7180069ce0085f11c3c1b9a73eb9ec5 (patch) | |
| tree | d7888c4e9d04556705bb4e86a7a1686f6c8c6f28 /src | |
| parent | e4861e6e2ffb21ea1ec44041fa1eea8044d78dae (diff) | |
| download | rabbitmq-server-git-c08f792cf7180069ce0085f11c3c1b9a73eb9ec5.tar.gz | |
Minor refactor
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_backing_queue_qc.erl | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/rabbit_backing_queue_qc.erl b/src/rabbit_backing_queue_qc.erl index 9aaee16032..6424976a2d 100644 --- a/src/rabbit_backing_queue_qc.erl +++ b/src/rabbit_backing_queue_qc.erl @@ -38,7 +38,7 @@ -record(state, {bqstate, len, %% int messages, %% queue of {msg_props, basic_msg} - acks, %% list of {acktag, {message_props, basic_msg}} + acks, %% list of {acktag, {msg_props, basic_msg}} confirms}). %% set of msgid %% Initialise model @@ -297,12 +297,10 @@ repeat(Result, _Fun, 0) -> repeat(Result, Fun, Times) -> repeat(Fun(Result), Fun, Times - 1). -publish_multiple(_Msg, _MsgProps, BQ, 0) -> - BQ; publish_multiple(Msg, MsgProps, BQ, Count) -> - publish_multiple(Msg, MsgProps, - ?BQMOD:publish(Msg, MsgProps, self(), BQ), - Count - 1). + repeat(BQ, fun(BQ1) -> + ?BQMOD:publish(Msg, MsgProps, self(), BQ1) + end, Count). timeout(BQ, 0) -> BQ; |