diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 422b0d5902..da01e0764b 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -707,8 +707,8 @@ process_instruction({fetch, AckRequired, MsgId, Remaining}, QLen = BQ:len(BQS), {ok, case QLen - 1 of Remaining -> - {{_Msg, _IsDelivered, AckTag, Remaining}, BQS1} = - BQ:fetch(AckRequired, BQS), + {{#basic_message{id = MsgId}, _IsDelivered, + AckTag, Remaining}, BQS1} = BQ:fetch(AckRequired, BQS), maybe_store_ack(AckRequired, MsgId, AckTag, State #state { backing_queue_state = BQS1 }); Other when Other < Remaining -> |