diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-04 14:35:45 +0000 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-04 14:35:45 +0000 |
commit | 9747729547c1ae333b09f00d9ac0801d0b2b4c70 (patch) | |
tree | 88144a81434049bb96b812d369e16e51e66ae2a1 /src/rabbit_queue_consumers.erl | |
parent | b2e24166a4b22c0794a2e058f1cfca98829bc811 (diff) | |
download | rabbitmq-server-9747729547c1ae333b09f00d9ac0801d0b2b4c70.tar.gz |
Strip out support for x-prefetch.
Diffstat (limited to 'src/rabbit_queue_consumers.erl')
-rw-r--r-- | src/rabbit_queue_consumers.erl | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl index 47b4ef3a..8c11d5d0 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -135,7 +135,6 @@ add(ChPid, CTag, NoAck, LimiterPid, LimiterActive, Prefetch, Args, IsEmpty, C1 = C#cr{consumer_count = Count + 1, limiter = Limiter1}, update_ch_record( case parse_credit_args(Prefetch, Args) of - none -> C1; {0, auto} -> C1; {_Credit, auto} when NoAck -> C1; {Credit, Mode} -> credit_and_drain( @@ -357,10 +356,7 @@ parse_credit_args(Default, Args) -> {{long, C}, {bool, D}} -> {C, drain_mode(D)}; _ -> {Default, auto} end; - undefined -> case rabbit_misc:table_lookup(Args, <<"x-prefetch">>) of - {_, Prefetch} -> {Prefetch, auto}; - _ -> {Default, auto} - end + undefined -> {Default, auto} end. lookup_ch(ChPid) -> |