diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 6f5a879bf0..b1f0962257 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1296,7 +1296,9 @@ handle_cast({dead_letter, Msgs, Reason}, State = #q{dlx = XName}) -> unconfirmed = UC1} end, State, Msgs)); {error, not_found} -> - cleanup_after_confirm([AckTag || {_, AckTag} <- Msgs], State) + cleanup_after_confirm( + [AckTag || {_, AckTag} <- Msgs], + State#q{publish_seqno = State#q.publish_seqno + length(Msgs)}) end; handle_cast(wake_up, State) -> |