diff --git a/deps/rabbit/docs/rabbitmq.conf.example b/deps/rabbit/docs/rabbitmq.conf.example index 4f69d18b3c..9fdcf44e9b 100644 --- a/deps/rabbit/docs/rabbitmq.conf.example +++ b/deps/rabbit/docs/rabbitmq.conf.example @@ -384,6 +384,16 @@ ## properties that may conflict or significantly change queue behavior and semantics, such as the 'exclusive' field. # quorum_queue.property_equivalence.relaxed_checks_on_redeclaration = true +## Sets the initial quorum queue cluster size for newly declared quorum queues. +## This value will be overridden if the 'x-quorum-initial-group-size' queue argument is provided. +# quorum_queue.cluster_size = 3 + +## Sets the maximum number of unconfirmed messages a channel can send +## before publisher flow control is triggered. +## The current default is configured to provide good performance and stability +## when there are multiple publishers sending to the same quorum queue. +# quorum_queue.commands_soft_limit = 32 + ## Changes classic queue storage implementation version. ## In 4.0.x, version 2 is the default and this is a forward compatibility setting, ## that is, it will be useful when a new version is developed. diff --git a/deps/rabbit/priv/schema/rabbit.schema b/deps/rabbit/priv/schema/rabbit.schema index e3fdc98475..4e9a629f7a 100644 --- a/deps/rabbit/priv/schema/rabbit.schema +++ b/deps/rabbit/priv/schema/rabbit.schema @@ -2610,6 +2610,15 @@ end}. {mapping, "quorum_queue.property_equivalence.relaxed_checks_on_redeclaration", "rabbit.quorum_relaxed_checks_on_redeclaration", [ {datatype, {enum, [true, false]}}]}. +{mapping, "quorum_queue.cluster_size", "rabbit.quorum_cluster_size", [ + {datatype, integer}, + {validators, ["non_zero_positive_integer"]} +]}. + +{mapping, "quorum_queue.commands_soft_limit", "rabbit.quorum_commands_soft_limit", [ + {datatype, integer}, + {validators, ["non_zero_positive_integer"]} +]}. %% %% Quorum Queue membership reconciliation diff --git a/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets b/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets index cc353e2333..5c7344304a 100644 --- a/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets +++ b/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets @@ -1067,6 +1067,20 @@ credential_validator.regexp = ^abc\\d+", ]}], []}, + {quorum_cluster_size, + "quorum_queue.cluster_size = 3", + [{rabbit, [ + {quorum_cluster_size, 3} + ]}], + []}, + + {quorum_commands_soft_limit, + "quorum_queue.commands_soft_limit = 32", + [{rabbit, [ + {quorum_commands_soft_limit, 32} + ]}], + []}, + %% %% Runtime parameters %%