diff options
| author | Marek Majkowski <marek@rabbitmq.com> | 2011-02-04 13:42:51 +0000 |
|---|---|---|
| committer | Marek Majkowski <marek@rabbitmq.com> | 2011-02-04 13:42:51 +0000 |
| commit | 91fa60797b8183a2dcd3ceac362f78bfb9560b1f (patch) | |
| tree | b1be844b3313527129025f66cd88b5d636ac9f97 | |
| parent | 79586c1a0b2b788105da3c84ff8e207e025e6694 (diff) | |
| download | rabbitmq-server-git-91fa60797b8183a2dcd3ceac362f78bfb9560b1f.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_channel.erl | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index ebd8b15c8b..87357b89f2 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1239,17 +1239,15 @@ is_message_persistent(Content) -> IsPersistent end. -process_routing_result(unroutable, _, XName, MsgSeqNo, - Msg = #basic_message{exchange_name = ExchangeName}, - State) -> +process_routing_result(unroutable, _, XName, MsgSeqNo, Msg, State) -> ok = basic_return(Msg, State#ch.writer_pid, no_route), - maybe_incr_stats([{ExchangeName, 1}], return_unroutable, State), + maybe_incr_stats([{Msg#basic_message.exchange_name, 1}], + return_unroutable, State), record_confirm(MsgSeqNo, XName, State); -process_routing_result(not_delivered, _, XName, MsgSeqNo, - Msg = #basic_message{exchange_name = ExchangeName}, - State) -> +process_routing_result(not_delivered, _, XName, MsgSeqNo, Msg, State) -> ok = basic_return(Msg, State#ch.writer_pid, no_consumers), - maybe_incr_stats([{ExchangeName, 1}], return_not_delivered, State), + maybe_incr_stats([{Msg#basic_message.exchange_name, 1}], + return_not_delivered, State), record_confirm(MsgSeqNo, XName, State); process_routing_result(routed, [], XName, MsgSeqNo, _, State) -> record_confirm(MsgSeqNo, XName, State); |