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 | 5731ddd078a5223f555ccead4af5c8e901545db3 (patch) | |
| tree | ec77f2075f23d3cb75373a90389ddd4b98bf1716 /src | |
| parent | 124d0ac98444b44caab8ed92b16174658f6d1656 (diff) | |
| download | rabbitmq-server-git-5731ddd078a5223f555ccead4af5c8e901545db3.tar.gz | |
inline (and avoid misleading var name in the process)
Diffstat (limited to 'src')
| -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 92b00db066..8d7535f8fc 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, |