diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-22 15:20:39 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-22 15:20:39 +0000 |
| commit | a30304a354046f56aa1255ef7b9135199fbbe23e (patch) | |
| tree | e141598fead9cf0f25171f63db686303b29de4d3 | |
| parent | ea1845737ef87615f0ad3a25a181bf25968a6bc7 (diff) | |
| download | rabbitmq-server-a30304a354046f56aa1255ef7b9135199fbbe23e.tar.gz | |
consistency
| -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 57a2d6f9..41fc173b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -755,7 +755,7 @@ dead_letter_msg_existing_dlx(Msg, AckTag, Reason, State1 = lists:foldl(fun monitor_queue/2, State, QPids), State2 = State1#q{publish_seqno = MsgSeqNo + 1}, case QPids of - [] -> {_, BQS1} = BQ:ack([AckTag], BQS), + [] -> {_Guids, BQS1} = BQ:ack([AckTag], BQS), cleanup_after_confirm(State2#q{backing_queue_state = BQS1}); _ -> State3 = lists:foldl( |