diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-01-08 17:37:37 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-01-08 19:28:05 +0300 |
| commit | 71d17fb920403a875f83ef985e48a016a3e67761 (patch) | |
| tree | db1f7523768fb0a275eea7e6836985c751096b74 /src | |
| parent | a8d826dc9b7bd433a7d433cb7eead81e6f211264 (diff) | |
| download | rabbitmq-server-git-71d17fb920403a875f83ef985e48a016a3e67761.tar.gz | |
Clarify comments
(cherry picked from commit 14e232f2afbd4dd212f0eae1c4efcde3d250b11e)
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_consumers.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl index 83a2d39ca7..e743fbce18 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -43,7 +43,7 @@ acktags, consumer_count, %% Queue of {ChPid, #consumer{}} for consumers which have - %% been blocked for any reason + %% been blocked (rate/prefetch limited) for any reason blocked_consumers, %% The limiter itself limiter, @@ -203,7 +203,7 @@ deliver(_FetchFun, _QName, false, State, true, none) -> State#state{use = update_use(State#state.use, inactive)}}; deliver(FetchFun, QName, false, State = #state{consumers = Consumers}, true, SingleActiveConsumer) -> {ChPid, Consumer} = SingleActiveConsumer, - %% blocked consumers are removed from the queue state, but not the exclusive_consumer field, + %% blocked (rate/prefetch limited) consumers are removed from the queue state, but not the exclusive_consumer field, %% so we need to do this check to avoid adding the exclusive consumer to the channel record %% over and over case is_blocked(SingleActiveConsumer) of |