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 | 4a33db73ff8004bff84c6e73893e0c96ae771ccc (patch) | |
| tree | 6ccf49949ba3f90eb880d1d6ecacd3db80b788ae | |
| parent | 66e27badc649e5d928d59631f8478300171c7730 (diff) | |
| download | rabbitmq-server-git-4a33db73ff8004bff84c6e73893e0c96ae771ccc.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 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) -> |