diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-08-13 02:37:26 +1000 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-08-13 02:37:26 +1000 |
| commit | f47a339b8e528eaaa8b84e5be146a92ee687b99f (patch) | |
| tree | 1d4fa6055649ac52742423d70dd554504b371b47 | |
| parent | d6e7c3841c5f01933e9182da1701bd2ac74eb1ff (diff) | |
| download | rabbitmq-server-git-f47a339b8e528eaaa8b84e5be146a92ee687b99f.tar.gz | |
Only send force_event_refresh events to classic queues
Pair: @dcorbacho.
Closes #2077.
References #2049.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 65691cedd0..ad6a183dfc 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -1047,8 +1047,11 @@ list_local(VHostPath) -> % This event is necessary for the stats timer to be initialized with % the correct values once the management agent has started force_event_refresh(Ref) -> + %% note: quorum queuse emit stats on periodic ticks that run unconditionally, + %% so force_event_refresh is unnecessary (and, in fact, would only produce log noise) for QQs. + ClassicQs = list_by_type(rabbit_classic_queue), [gen_server2:cast(amqqueue:get_pid(Q), - {force_event_refresh, Ref}) || Q <- list()], + {force_event_refresh, Ref}) || Q <- ClassicQs], ok. -spec notify_policy_changed(amqqueue:amqqueue()) -> 'ok'. |