Skip to content

Commit 4452872

Browse files
committed
Local shovels: Update default credit
1 parent a419ab3 commit 4452872

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

deps/rabbitmq_shovel/priv/schema/rabbitmq_shovel.schema

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,3 +9,7 @@
99
{mapping, "shovel.topology.predeclared", "rabbitmq_shovel.topology.predeclared", [
1010
[{datatype, {enum, [true, false]}}]
1111
]}.
12+
13+
{mapping, "max_local_shovel_credit", "rabbitmq_shovel.max_local_shovel_credit", [
14+
{datatype, integer}
15+
]}.

deps/rabbitmq_shovel/src/rabbit_local_shovel.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@
5252
%% sequence number initialized at an arbitrary point by the sender."
5353
%% See rabbit_amqp_session.erl
5454
-define(INITIAL_DELIVERY_COUNT, 16#ff_ff_ff_ff - 4).
55-
-define(DEFAULT_MAX_LINK_CREDIT, 170).
55+
-define(DEFAULT_MAX_LINK_CREDIT, 1000).
5656

5757
-record(pending_ack, {
5858
delivery_tag,
@@ -677,7 +677,7 @@ maybe_grant_credit(#{source := #{queue_r := QName,
677677
handle_queue_actions(Actions, State).
678678

679679
max_link_credit() ->
680-
application:get_env(rabbit, max_link_credit, ?DEFAULT_MAX_LINK_CREDIT).
680+
application:get_env(rabbitmq_shovel, max_local_shovel_credit, ?DEFAULT_MAX_LINK_CREDIT).
681681

682682
grant_link_credit(Credit, MaxLinkCredit, NumUnconfirmed) ->
683683
Credit =< MaxLinkCredit div 2 andalso

0 commit comments

Comments
 (0)