diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-10 16:20:49 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-10 16:20:49 +0100 |
| commit | dbbb424225d52fc41be696cec9f9ba462daf19c0 (patch) | |
| tree | 6ccf49949ba3f90eb880d1d6ecacd3db80b788ae | |
| parent | 4728b927b095ed69b68345e5622dbb9796c97cb1 (diff) | |
| download | rabbitmq-server-dbbb424225d52fc41be696cec9f9ba462daf19c0.tar.gz | |
increase the seqno when the DLX is not found
| -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 6f5a879b..b1f09622 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) -> |