Skip to content

Commit 96317be

Browse files
committed
Add x-quorum-target-group-size
1 parent 493d19d commit 96317be

File tree

2 files changed

+13
-5
lines changed

2 files changed

+13
-5
lines changed

deps/rabbit/src/rabbit_quorum_queue_periodic_membership_reconciliation.erl

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -201,11 +201,18 @@ get_target_size(Q, N) when N > 0 ->
201201
max(N, get_target_size(Q)).
202202

203203
get_target_size(Q) ->
204-
case rabbit_policy:get(<<"target-group-size">>, Q) of
204+
PolicyValue = case rabbit_policy:get(<<"target-group-size">>, Q) of
205+
undefined ->
206+
0;
207+
PolicyN ->
208+
PolicyN
209+
end,
210+
Arguments = amqqueue:get_arguments(Q),
211+
case rabbit_misc:table_lookup(Arguments, <<"x-quorum-target-group-size">>) of
205212
undefined ->
206-
0;
207-
N ->
208-
N
213+
PolicyValue;
214+
ArgN ->
215+
max(ArgN, PolicyValue)
209216
end.
210217

211218
remove_members(_Q, []) ->

deps/rabbitmq_management/priv/www/js/tmpl/queues.ejs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -336,7 +336,8 @@
336336
<% if (queue_type == "quorum") { %>
337337
<span class="argument-link" field="arguments" key="x-delivery-limit" type="number">Delivery limit</span><span class="help" id="delivery-limit"></span>
338338
| <span class="argument-link" field="arguments" key="x-quorum-initial-group-size" type="number">Initial cluster size</span><span class="help" id="queue-initial-cluster-size"></span><br/>
339-
<span class="argument-link" field="arguments" key="x-dead-letter-strategy" type="string">Dead letter strategy</span><span class="help" id="queue-dead-letter-strategy"></span>
339+
| <span class="argument-link" field="arguments" key="x-quorum-target-group-size" type="number">Target cluster size</span><span class="help" id="qourum-queue-target-group-size"></span>
340+
<span class="argument-link" field="arguments" key="x-dead-letter-strategy" type="string">Dead letter strategy</span><span class="help" id="queue-dead-letter-strategy"></span>
340341
<% } %>
341342
<% if (queue_type == "stream") { %>
342343
<span class="argument-link" field="arguments" key="x-max-age" type="string">Max time retention</span><span class="help" id="queue-max-age"></span>

0 commit comments

Comments
 (0)