summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2017-08-24 05:31:34 -0400
committerMichael Klishin <michael@clojurewerkz.org>2017-08-24 05:31:34 -0400
commitef1a5a0596e022cae8310d6e04c667c28b6902cc (patch)
treeefa774003e29bc233a8530169f34f8f2ce5a0bc2 /src
parent1bc84822a10255319be6170d74355f20cef5fa5f (diff)
parent677f22a87560d83745f5bd4d5df0c60ee550a38d (diff)
downloadrabbitmq-server-git-ef1a5a0596e022cae8310d6e04c667c28b6902cc.tar.gz
Merge branch 'stable'
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_core_metrics_gc.erl9
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()),