Skip to content

Commit f47a339

Browse files
Only send force_event_refresh events to classic queues
Pair: @dcorbacho. Closes #2077. References #2049.
1 parent d6e7c38 commit f47a339

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/rabbit_amqqueue.erl

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1047,8 +1047,11 @@ list_local(VHostPath) ->
10471047
% This event is necessary for the stats timer to be initialized with
10481048
% the correct values once the management agent has started
10491049
force_event_refresh(Ref) ->
1050+
%% note: quorum queuse emit stats on periodic ticks that run unconditionally,
1051+
%% so force_event_refresh is unnecessary (and, in fact, would only produce log noise) for QQs.
1052+
ClassicQs = list_by_type(rabbit_classic_queue),
10501053
[gen_server2:cast(amqqueue:get_pid(Q),
1051-
{force_event_refresh, Ref}) || Q <- list()],
1054+
{force_event_refresh, Ref}) || Q <- ClassicQs],
10521055
ok.
10531056

10541057
-spec notify_policy_changed(amqqueue:amqqueue()) -> 'ok'.

0 commit comments

Comments
 (0)