root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Init dead letter counter once 

follow up from https://github.com/rabbitmq/rabbitmq-server/pull/9080

Call rabbit_global_counters:init/1 just once.
This commit is contained in:
David Ansari 2023-08-16 08:54:28 +02:00
parent a6c5820e47
commit 939540f6dd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
deps/rabbitmq_mqtt/src/rabbit_mqtt.erl vendored
View File

@ -96,16 +96,16 @@ local_connection_pids() ->
init_global_counters() ->
lists:foreach(fun init_global_counters/1, [?MQTT_PROTO_V3,
?MQTT_PROTO_V4,
?MQTT_PROTO_V5]).
?MQTT_PROTO_V5]),
rabbit_global_counters:init([{queue_type, ?QUEUE_TYPE_QOS_0}, {dead_letter_strategy, disabled}],
[?MESSAGES_DEAD_LETTERED_MAXLEN_COUNTER]).
init_global_counters(ProtoVer) ->
Proto = {protocol, ProtoVer},
rabbit_global_counters:init([Proto]),
rabbit_global_counters:init([Proto, {queue_type, rabbit_classic_queue}]),
rabbit_global_counters:init([Proto, {queue_type, rabbit_quorum_queue}]),
rabbit_global_counters:init([Proto, {queue_type, ?QUEUE_TYPE_QOS_0}]),
rabbit_global_counters:init([{queue_type, ?QUEUE_TYPE_QOS_0}, {dead_letter_strategy, disabled}],
[?MESSAGES_DEAD_LETTERED_MAXLEN_COUNTER]).
rabbit_global_counters:init([Proto, {queue_type, ?QUEUE_TYPE_QOS_0}]).
persist_static_configuration() ->
rabbit_mqtt_util:init_sparkplug(),