Add quorum queue config in INI style
This commit is contained in:
parent
1aa3342590
commit
e557ab37a3
|
@ -384,6 +384,16 @@
|
||||||
## properties that may conflict or significantly change queue behavior and semantics, such as the 'exclusive' field.
|
## 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
|
# 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.
|
## Changes classic queue storage implementation version.
|
||||||
## In 4.0.x, version 2 is the default and this is a forward compatibility setting,
|
## 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.
|
## that is, it will be useful when a new version is developed.
|
||||||
|
|
|
@ -2610,6 +2610,15 @@ end}.
|
||||||
{mapping, "quorum_queue.property_equivalence.relaxed_checks_on_redeclaration", "rabbit.quorum_relaxed_checks_on_redeclaration", [
|
{mapping, "quorum_queue.property_equivalence.relaxed_checks_on_redeclaration", "rabbit.quorum_relaxed_checks_on_redeclaration", [
|
||||||
{datatype, {enum, [true, false]}}]}.
|
{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
|
%% Quorum Queue membership reconciliation
|
||||||
|
|
|
@ -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
|
%% Runtime parameters
|
||||||
%%
|
%%
|
||||||
|
|
Loading…
Reference in New Issue