diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2015-04-16 22:28:18 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2015-04-16 22:28:18 +0300 |
| commit | 0b91553bafde0e063714b9557a1a76dc5213163b (patch) | |
| tree | 1486ac42f68dbeb1a42a60e0b02b7ec02fb57f3c /src | |
| parent | 50597aa117bf2017fa4a66b2de67feda3f5d7c41 (diff) | |
| download | rabbitmq-server-git-0b91553bafde0e063714b9557a1a76dc5213163b.tar.gz | |
Make gm flow control configurable
Fixes #114.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 4e2a9e11f7..ba98175299 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -797,7 +797,14 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, QNames = rabbit_exchange:route(Exchange, Delivery), rabbit_trace:tap_in(Message, QNames, ConnName, ChannelNum, Username, TraceState), - DQ = {Delivery#delivery{flow = flow}, QNames}, + %% flow | noflow, see rabbitmq-server#114 + Flow = case get(gm_flow_control) of + undefined -> V = rabbit_misc:get_env(rabbit, gm_flow_control, flow), + put(gm_flow_control, V), + V; + V -> V + end, + DQ = {Delivery#delivery{flow = Flow}, QNames}, {noreply, case Tx of none -> deliver_to_queues(DQ, State1); {Msgs, Acks} -> Msgs1 = queue:in(DQ, Msgs), |