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