diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-10-05 18:03:56 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-10-05 18:03:56 +0100 |
| commit | ce21bc83e70cfc8eb89aecc22d84a77c0175024b (patch) | |
| tree | dfbb37b433def5d4bfe7e2358e0ad13f5cd872a6 /src/rabbit_amqqueue_process.erl | |
| parent | 70e398700b73ed51129407dd69fd686325155094 (diff) | |
| download | rabbitmq-server-ce21bc83e70cfc8eb89aecc22d84a77c0175024b.tar.gz | |
swap the arguments of ack/2
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 9abe9069..cab77c1b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -423,7 +423,7 @@ record_confirm_message(#delivery{msg_seq_no = MsgSeqNo, ack_by_acktags(AckTags, State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> - {BQS1, AckdGuids} = BQ:ack(AckTags, BQS), + {AckdGuids, BQS1} = BQ:ack(AckTags, BQS), confirm_messages(AckdGuids, State#q{backing_queue_state = BQS1}). run_message_queue(State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> |