diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-11 15:07:17 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-11 15:07:17 +0100 |
| commit | ba5b3bb9f3405daf71bf8ff40a04ce11eb7d6668 (patch) | |
| tree | 9be49e46cc226570c2e758f7d4d60545dc7476cb | |
| parent | 4a33db73ff8004bff84c6e73893e0c96ae771ccc (diff) | |
| download | rabbitmq-server-git-ba5b3bb9f3405daf71bf8ff40a04ce11eb7d6668.tar.gz | |
do not bump the publish seqno when we can't publish DLX'ed msgs
Emile notices that it's not necessary
| -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) -> |