diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-15 18:05:55 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-15 18:05:55 +0000 |
| commit | 4edf76b369491de4e9bb18a4f5df571c10e411de (patch) | |
| tree | ec77f2075f23d3cb75373a90389ddd4b98bf1716 | |
| parent | f1e03821a9b62e1f28ffddf0a4ee4fa31006461b (diff) | |
| download | rabbitmq-server-4edf76b369491de4e9bb18a4f5df571c10e411de.tar.gz | |
inline (and avoid misleading var name in the process)
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 92b00db0..8d7535f8 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -762,8 +762,8 @@ dead_letter_publish(Msg, Reason, X, State = #q{publish_seqno = MsgSeqNo}) -> {Queues, Cycles} = detect_dead_letter_cycles( DLMsg, rabbit_exchange:route(X, Delivery)), lists:foreach(fun log_cycle_once/1, Cycles), - QPids = rabbit_amqqueue:lookup(Queues), - {_, DeliveredQPids} = rabbit_amqqueue:deliver(QPids, Delivery), + {_, DeliveredQPids} = rabbit_amqqueue:deliver( + rabbit_amqqueue:lookup(Queues), Delivery), DeliveredQPids. handle_queue_down(QPid, Reason, State = #q{queue_monitors = QMons, |