diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-06 14:49:15 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-06 14:49:15 +0000 |
| commit | 1bf14fc95d24cb1502684f2c6fe7ef3074c777b7 (patch) | |
| tree | 8e6796a562ebec48d24843fac86a48ab5d79cbb6 | |
| parent | defcba9da9a168ebe775a8c85bcea2c75ab32b76 (diff) | |
| download | rabbitmq-server-git-1bf14fc95d24cb1502684f2c6fe7ef3074c777b7.tar.gz | |
Start the consumer utilisation average at active 100% of the time, since when we first add a first consumer it will not be blocked.
| -rw-r--r-- | src/rabbit_queue_consumers.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl index c9540da818..177cb9e83e 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -97,7 +97,7 @@ %%---------------------------------------------------------------------------- new() -> #state{consumers = priority_queue:new(), - use = {inactive, now_micros(), 0, 0.0}}. + use = {active, now_micros(), 1.0}}. max_active_priority(#state{consumers = Consumers}) -> priority_queue:highest(Consumers). |