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 | 75db54a656b13a6d9e2bfd0b7ebffb30b494a42a (patch) | |
| tree | 6133159464d2842f19d65c7b0843bfec6f763a32 | |
| parent | ba5b3bb9f3405daf71bf8ff40a04ce11eb7d6668 (diff) | |
| download | rabbitmq-server-git-75db54a656b13a6d9e2bfd0b7ebffb30b494a42a.tar.gz | |
cosmetics
| -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 6f5a879bf0..20ba457465 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} |