diff options
| author | Marek Majkowski <marek@rabbitmq.com> | 2010-12-08 10:01:04 +0000 |
|---|---|---|
| committer | Marek Majkowski <marek@rabbitmq.com> | 2010-12-08 10:01:04 +0000 |
| commit | a7954f85cfa85da9e3eab7d2b8e5fb4bac27e440 (patch) | |
| tree | 73abf675b805558a97be3b61bf6589d59ee31ed7 /src | |
| parent | 1ffd85e580b5d5e8e7bb6b7123126933aa1cf168 (diff) | |
| download | rabbitmq-server-git-a7954f85cfa85da9e3eab7d2b8e5fb4bac27e440.tar.gz | |
Add 'return' stats
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 0c8ad00ae3..ada63ca21a 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1219,10 +1219,16 @@ is_message_persistent(Content) -> IsPersistent end. -process_routing_result(unroutable, _, MsgSeqNo, Message, State) -> +process_routing_result(unroutable, _, MsgSeqNo, + Message = #basic_message{exchange_name = ExchangeName}, + State) -> + maybe_incr_stats([{ExchangeName, 1}], return, State), ok = basic_return(Message, State#ch.writer_pid, no_route), send_or_enqueue_ack(MsgSeqNo, undefined, State); -process_routing_result(not_delivered, _, MsgSeqNo, Message, State) -> +process_routing_result(not_delivered, _, MsgSeqNo, + Message = #basic_message{exchange_name = ExchangeName}, + State) -> + maybe_incr_stats([{ExchangeName, 1}], return, State), ok = basic_return(Message, State#ch.writer_pid, no_consumers), send_or_enqueue_ack(MsgSeqNo, undefined, State); process_routing_result(routed, [], MsgSeqNo, _, State) -> |