@@ -577,6 +577,8 @@ get_data(Table, false, VHostsFilter) when Table == channel_exchange_metrics;
577
577
Acc ;
578
578
({# resource {kind = queue , virtual_host = VHost }, _ , _ , _ , _ , _ , _ , _ , _ }, Acc ) when is_map (VHostsFilter ), map_get (VHost , VHostsFilter ) == false ->
579
579
Acc ;
580
+ ({{# resource {kind = queue , virtual_host = VHost }, # resource {kind = exchange }}, _ , _ }, Acc ) when is_map (VHostsFilter ), map_get (VHost , VHostsFilter ) == false ->
581
+ Acc ;
580
582
({_ , V1 }, {T , A1 }) ->
581
583
{T , V1 + A1 };
582
584
({_ , V1 , _ }, {T , A1 }) ->
@@ -612,9 +614,7 @@ get_data(exchange_metrics = Table, true, VHostsFilter) when is_map(VHostsFilter)
612
614
(_Row , Acc ) ->
613
615
Acc
614
616
end , [], Table );
615
- get_data (exchange_metrics , true , _VhostsFilter ) ->
616
- [];
617
- get_data (queue_counter_metrics = Table , true , VHostsFilter ) when is_map (VHostsFilter )->
617
+ get_data (queue_counter_metrics = Table , true , VHostsFilter ) when is_map (VHostsFilter ) ->
618
618
ets :foldl (fun
619
619
({# resource {kind = queue , virtual_host = VHost }, _ , _ , _ , _ , _ , _ , _ , _ } = Row , Acc ) when
620
620
map_get (VHost , VHostsFilter )
@@ -623,9 +623,7 @@ get_data(queue_counter_metrics = Table, true, VHostsFilter) when is_map(VHostsFi
623
623
(_Row , Acc ) ->
624
624
Acc
625
625
end , [], Table );
626
- get_data (queue_counter_metrics , true , _VHostsFilter ) ->
627
- [];
628
- get_data (queue_exchange_metrics = Table , true , VHostsFilter ) ->
626
+ get_data (queue_exchange_metrics = Table , true , VHostsFilter ) when is_map (VHostsFilter ) ->
629
627
ets :foldl (fun
630
628
({{
631
629
# resource {kind = queue , virtual_host = VHost },
@@ -637,8 +635,6 @@ get_data(queue_exchange_metrics = Table, true, VHostsFilter) ->
637
635
(_Row , Acc ) ->
638
636
Acc
639
637
end , [], Table );
640
- get_data (queue_exchange_metrics , true , _VHostsFilter ) ->
641
- [];
642
638
get_data (queue_coarse_metrics = Table , true , VHostsFilter ) when is_map (VHostsFilter ) ->
643
639
ets :foldl (fun
644
640
({# resource {kind = queue , virtual_host = VHost }, _ , _ , _ , _ } = Row , Acc ) when map_get (VHost , VHostsFilter ) ->
0 commit comments