diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-04-25 18:12:59 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-04-25 18:12:59 +0300 |
| commit | 84cf22a44bee8c6e27b6216374c2d52ff20e87f8 (patch) | |
| tree | 63774c5532ed56197823c7846ece21b9c25c4f1f /src | |
| parent | 0d67fc1007f38a49b8e561bbd4db4ffba1666bd1 (diff) | |
| parent | a359b43be83666346c1f878dc1421c3fc275022e (diff) | |
| download | rabbitmq-server-git-84cf22a44bee8c6e27b6216374c2d52ff20e87f8.tar.gz | |
Merge pull request #1988 from rabbitmq/rabbitmq-server-1904
Track messages that were not routed anywhere and also not published as mandatory
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 12 | ||||
| -rw-r--r-- | src/rabbit_core_metrics_gc.erl | 2 |
2 files changed, 11 insertions, 3 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index ff6186ad84..69add85057 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -2111,8 +2111,9 @@ notify_limiter(Limiter, Acked) -> deliver_to_queues({#delivery{message = #basic_message{exchange_name = XName}, confirm = false, mandatory = false}, - []}, State) -> %% optimisation + _RoutedToQs = []}, State) -> %% optimisation ?INCR_STATS(exchange_stats, XName, 1, publish, State), + ?INCR_STATS(exchange_stats, XName, 1, drop_unroutable, State), State; deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ exchange_name = XName}, @@ -2165,9 +2166,16 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ end, State2#ch{queue_states = QueueStates}. -process_routing_mandatory(true, [], Msg, State) -> +process_routing_mandatory(_Mandatory = true, + _RoutedToQs = [], + Msg, State) -> ok = basic_return(Msg, State, no_route), ok; +process_routing_mandatory(_Mandatory = false, + _RoutedToQs = [], + #basic_message{exchange_name = ExchangeName}, State) -> + ?INCR_STATS(exchange_stats, ExchangeName, 1, drop_unroutable, State), + ok; process_routing_mandatory(_, _, _, _) -> ok. diff --git a/src/rabbit_core_metrics_gc.erl b/src/rabbit_core_metrics_gc.erl index f4980aec7d..99ad8eef34 100644 --- a/src/rabbit_core_metrics_gc.erl +++ b/src/rabbit_core_metrics_gc.erl @@ -157,7 +157,7 @@ gc_process_and_entity(Table, GbSet) -> ets:foldl(fun({{Pid, Id} = Key, _, _, _, _, _, _, _, _}, none) when Table == channel_queue_metrics -> gc_process_and_entity(Id, Pid, Table, Key, GbSet); - ({{Pid, Id} = Key, _, _, _, _}, none) + ({{Pid, Id} = Key, _, _, _, _, _}, none) when Table == channel_exchange_metrics -> gc_process_and_entity(Id, Pid, Table, Key, GbSet); ({{Id, Pid, _} = Key, _, _, _, _, _, _}, none) |