diff options
| -rw-r--r-- | src/rabbit_core_metrics_gc.erl | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/rabbit_core_metrics_gc.erl b/src/rabbit_core_metrics_gc.erl index 3321f2b5de..9396368348 100644 --- a/src/rabbit_core_metrics_gc.erl +++ b/src/rabbit_core_metrics_gc.erl @@ -70,10 +70,17 @@ gc_channels() -> ok. gc_queues() -> + gc_local_queues(), + gc_global_queues(). + +gc_local_queues() -> Queues = rabbit_amqqueue:list_local_names(), GbSet = gb_sets:from_list(Queues), gc_entity(queue_metrics, GbSet), - gc_entity(queue_coarse_metrics, GbSet), + gc_entity(queue_coarse_metrics, GbSet). + +gc_global_queues() -> + GbSet = gb_sets:from_list(rabbit_amqqueue:list_names()), gc_process_and_entity(channel_queue_metrics, GbSet), gc_process_and_entity(consumer_created, GbSet), ExchangeGbSet = gb_sets:from_list(rabbit_exchange:list_names()), |