diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-11 15:07:31 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-11 15:07:31 +0100 |
| commit | cbf6876df093db5c71e7cb100b880e309d837401 (patch) | |
| tree | 6133159464d2842f19d65c7b0843bfec6f763a32 | |
| parent | cf4d9a2ba41792eaf989d8ff3da48c4a2f32b49b (diff) | |
| download | rabbitmq-server-bug24888.tar.gz | |
cosmeticsbug24888
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 6f5a879b..20ba4574 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1284,13 +1284,13 @@ handle_cast({dead_letter, Msgs, Reason}, State = #q{dlx = XName}) -> case rabbit_exchange:lookup(XName) of {ok, X} -> noreply(lists:foldl( - fun({Msg, AckTag}, State1 = #q{publish_seqno = SeqNo, - unconfirmed = UC}) -> + fun({Msg, AckTag}, State1 = #q{publish_seqno = SeqNo, + unconfirmed = UC, + queue_monitors = QMon}) -> QPids = dead_letter_publish(Msg, Reason, X, State1), UC1 = dtree:insert(SeqNo, QPids, AckTag, UC), - QMons = pmon:monitor_all(QPids, - State1#q.queue_monitors), + QMons = pmon:monitor_all(QPids, QMon), State1#q{queue_monitors = QMons, publish_seqno = SeqNo + 1, unconfirmed = UC1} |