diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2017-08-23 11:56:16 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2017-08-23 11:56:16 +0100 |
| commit | 249cf662ccb1914633e0493b8356420b6a3ec726 (patch) | |
| tree | 0cad03321545c74e68b83083a33ca9c3b27d6e62 | |
| parent | b02a53eebde065e51e0dc9c4041756950003b0a2 (diff) | |
| download | rabbitmq-server-git-249cf662ccb1914633e0493b8356420b6a3ec726.tar.gz | |
Do not GC channel-queue metrics on mirror migration
rabbitmq-server#1340
[#150442817]
| -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()), |