Skip to content

Commit 99e9729

Browse files
Merge commit '228cbf9776'
(cherry picked from commit b11d853)
1 parent 620fed7 commit 99e9729

File tree

3 files changed

+34
-0
lines changed

3 files changed

+34
-0
lines changed

deps/rabbit/docs/rabbitmq.conf.example

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -384,6 +384,17 @@
384384
## properties that may conflict or significantly change queue behavior and semantics, such as the 'exclusive' field.
385385
# quorum_queue.property_equivalence.relaxed_checks_on_redeclaration = true
386386

387+
## Sets the initial quorum queue replica count for newly declared quorum queues.
388+
## This value can be overridden using the 'x-quorum-initial-group-size' queue argument
389+
## at declaration time.
390+
# quorum_queue.initial_cluster_size = 3
391+
392+
## Sets the maximum number of unconfirmed messages a channel can send
393+
## before publisher flow control is triggered.
394+
## The current default is configured to provide good performance and stability
395+
## when there are multiple publishers sending to the same quorum queue.
396+
# quorum_queue.commands_soft_limit = 32
397+
387398
## Changes classic queue storage implementation version.
388399
## In 4.0.x, version 2 is the default and this is a forward compatibility setting,
389400
## that is, it will be useful when a new version is developed.

deps/rabbit/priv/schema/rabbit.schema

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2610,6 +2610,15 @@ end}.
26102610
{mapping, "quorum_queue.property_equivalence.relaxed_checks_on_redeclaration", "rabbit.quorum_relaxed_checks_on_redeclaration", [
26112611
{datatype, {enum, [true, false]}}]}.
26122612

2613+
{mapping, "quorum_queue.initial_cluster_size", "rabbit.quorum_cluster_size", [
2614+
{datatype, integer},
2615+
{validators, ["non_zero_positive_integer"]}
2616+
]}.
2617+
2618+
{mapping, "quorum_queue.commands_soft_limit", "rabbit.quorum_commands_soft_limit", [
2619+
{datatype, integer},
2620+
{validators, ["non_zero_positive_integer"]}
2621+
]}.
26132622

26142623
%%
26152624
%% Quorum Queue membership reconciliation

deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1067,6 +1067,20 @@ credential_validator.regexp = ^abc\\d+",
10671067
]}],
10681068
[]},
10691069

1070+
{quorum_queue_initial_cluster_size,
1071+
"quorum_queue.initial_cluster_size = 3",
1072+
[{rabbit, [
1073+
{quorum_cluster_size, 3}
1074+
]}],
1075+
[]},
1076+
1077+
{quorum_queue_commands_soft_limit,
1078+
"quorum_queue.commands_soft_limit = 32",
1079+
[{rabbit, [
1080+
{quorum_commands_soft_limit, 32}
1081+
]}],
1082+
[]},
1083+
10701084
%%
10711085
%% Runtime parameters
10721086
%%

0 commit comments

Comments
 (0)