diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-14 15:21:03 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-14 15:21:03 +0000 |
| commit | 0841aecc6986964c701afe323baa7fbdde0880cb (patch) | |
| tree | 796832c9653e2d0c56bd4c3537421c4715d9f527 /src | |
| parent | de50e31fb1fa20b5e5cdecd1617617b271ef7c9f (diff) | |
| download | rabbitmq-server-git-0841aecc6986964c701afe323baa7fbdde0880cb.tar.gz | |
Treat prefetch=0 the same as basic.qos does - it means infinity not a broken consumer
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_limiter.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index c0eecbefd7..5a5c478c87 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -293,6 +293,8 @@ credit(Limiter = #qstate{credits = Credits}, CTag, Credit, Drain, IsEmpty) -> set_consumer_prefetch(Lim, _CTag, true, _Credit) -> Lim; +set_consumer_prefetch(Lim, _CTag, _NoAck, 0) -> + Lim; set_consumer_prefetch(Lim = #qstate{credits = Credits}, CTag, false, Credit) -> Credits1 = gb_trees:enter( CTag, #credit{credit = Credit, mode = auto}, Credits), |