summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarek Majkowski <marek@rabbitmq.com>2011-02-04 13:42:51 +0000
committerMarek Majkowski <marek@rabbitmq.com>2011-02-04 13:42:51 +0000
commitcd64ab0f9b9fe0689a74681fed4e65d7ce333b8f (patch)
treeb1be844b3313527129025f66cd88b5d636ac9f97
parentc6e14cf23bcf5cebe1a9f2c3f44d1669d05cb961 (diff)
downloadrabbitmq-server-bug23580.tar.gz
cosmeticbug23580
-rw-r--r--src/rabbit_channel.erl14
1 files changed, 6 insertions, 8 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index ebd8b15c..87357b89 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);