root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

amqp_client.gc_threshold => amqp_client.writer_gc_threshold 

References #130.
This commit is contained in:
Michael Klishin 2019-12-24 23:35:22 +03:00
parent 70e817e40b
commit 1595a86c34
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/amqp_client/Makefile vendored
View File

@ -7,7 +7,7 @@ define PROJECT_ENV
[ [
{prefer_ipv6, false}, {prefer_ipv6, false},
{ssl_options, []}, {ssl_options, []},
{gc_threshold, 1000000000} {writer_gc_threshold, 1000000000}
] ]
endef endef

2
deps/amqp_client/src/amqp_channel_sup.erl vendored
View File

@ -58,7 +58,7 @@ start_writer(_Sup, direct, [ConnPid, Node, User, VHost, Collector, AmqpParams],
VHost, ?CLIENT_CAPABILITIES, Collector, AmqpParams]), VHost, ?CLIENT_CAPABILITIES, Collector, AmqpParams]),
RabbitCh; RabbitCh;
start_writer(Sup, network, [Sock, FrameMax], ConnName, ChNumber, ChPid) -> start_writer(Sup, network, [Sock, FrameMax], ConnName, ChNumber, ChPid) ->
GCThreshold = application:get_env(amqp_client, gc_threshold, ?DEFAULT_GC_THRESHOLD), GCThreshold = application:get_env(amqp_client, writer_gc_threshold, ?DEFAULT_GC_THRESHOLD),
{ok, Writer} = supervisor2:start_child( {ok, Writer} = supervisor2:start_child(
Sup, Sup,
{writer, {rabbit_writer, start_link, {writer, {rabbit_writer, start_link,

2
deps/amqp_client/src/amqp_connection_type_sup.erl vendored
View File

@ -54,7 +54,7 @@ start_infrastructure_fun(Sup, Conn, network) ->
fun (Sock, ConnName) -> fun (Sock, ConnName) ->
{ok, ChMgr} = start_channels_manager(Sup, Conn, ConnName, network), {ok, ChMgr} = start_channels_manager(Sup, Conn, ConnName, network),
{ok, AState} = rabbit_command_assembler:init(?PROTOCOL), {ok, AState} = rabbit_command_assembler:init(?PROTOCOL),
{ok, GCThreshold} = application:get_env(amqp_client, gc_threshold), {ok, GCThreshold} = application:get_env(amqp_client, writer_gc_threshold),
{ok, Writer} = {ok, Writer} =
supervisor2:start_child( supervisor2:start_child(
Sup, Sup,