diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-05 18:11:15 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-05 18:11:15 +0100 |
| commit | 2f3affece89d1cff8a40b120eacf63ce5b0f0147 (patch) | |
| tree | a37717c71ccf6548410427c71a8cfbd8ad48c977 | |
| parent | 1cd4e77393e74bbcb79cace93ed9af83a93314b2 (diff) | |
| download | rabbitmq-server-git-2f3affece89d1cff8a40b120eacf63ce5b0f0147.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_variable_queue.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 8c498a7917..cf61ecbe39 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -608,10 +608,9 @@ fetch(AckRequired, State = #vqstate { q4 = Q4, end. ack(AckTags, State) -> - {Guids, State1} = - ack(fun rabbit_msg_store:remove/2, - fun (_AckEntry, State1) -> State1 end, - AckTags, State), + {Guids, State1} = ack(fun rabbit_msg_store:remove/2, + fun (_AckEntry, State1) -> State1 end, + AckTags, State), {Guids, a(State1)}. tx_publish(Txn, Msg = #basic_message { is_persistent = IsPersistent }, |
