diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-12-24 23:38:29 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-12-24 23:38:29 +0300 |
| commit | 5e9e7a2aaffec1ddab93847798967100097493d1 (patch) | |
| tree | a92337f7e7ba2c37ce2624e10ec50735dbe59c4f /src | |
| parent | e86b5a623aafcdf6041816f27988a35fb7c5edc0 (diff) | |
| download | rabbitmq-server-git-5e9e7a2aaffec1ddab93847798967100097493d1.tar.gz | |
rabbit.gc_threshold => rabbit.writer_gc_threshold, references #2182
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index b1f22d48c2..41a9c6946a 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -171,7 +171,7 @@ queue_states, tick_timer, %% defines how ofter gc will be executed - gc_threshold + writer_gc_threshold }). -define(QUEUE, lqueue). @@ -510,7 +510,7 @@ init([Channel, ReaderPid, WriterPid, ConnPid, ConnName, Protocol, User, VHost, MaxMessageSize = get_max_message_size(), ConsumerTimeout = get_consumer_timeout(), OptionalVariables = extract_variable_map_from_amqp_params(AmqpParams), - {ok, GCThreshold} = application:get_env(rabbit, gc_threshold), + {ok, GCThreshold} = application:get_env(rabbit, writer_gc_threshold), State = #ch{cfg = #conf{state = starting, protocol = Protocol, channel = Channel, @@ -547,7 +547,7 @@ init([Channel, ReaderPid, WriterPid, ConnPid, ConnName, Protocol, User, VHost, delivery_flow = Flow, interceptor_state = undefined, queue_states = #{}, - gc_threshold = GCThreshold + writer_gc_threshold = GCThreshold }, State1 = State#ch{ interceptor_state = rabbit_channel_interceptor:init(State)}, @@ -1314,7 +1314,7 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, tx = Tx, confirm_enabled = ConfirmEnabled, delivery_flow = Flow, - gc_threshold = GCThreshold + writer_gc_threshold = GCThreshold }) -> check_msg_size(Content, MaxMessageSize, GCThreshold), ExchangeName = rabbit_misc:r(VHostPath, exchange, ExchangeNameBin), @@ -2695,7 +2695,7 @@ handle_deliver(ConsumerTag, AckRequired, content = Content}}, State = #ch{cfg = #conf{writer_pid = WriterPid}, next_tag = DeliveryTag, - gc_threshold = GCThreshold}) -> + writer_gc_threshold = GCThreshold}) -> Deliver = #'basic.deliver'{consumer_tag = ConsumerTag, delivery_tag = DeliveryTag, redelivered = Redelivered, |