diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-01-15 15:57:43 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-01-15 15:57:43 +0000 |
| commit | 6e0e3fcdc9b2760ace7f16537cbc6ad1cd94497e (patch) | |
| tree | e402153a270f3b691eeb345361880ae325e30b88 | |
| parent | 1470f8f387d16f88885a55d518249f302527ff5e (diff) | |
| download | rabbitmq-server-bug18557.tar.gz | |
add some commentsbug18557
| -rw-r--r-- | src/rabbit_channel.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_limiter.erl | 5 |
2 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 513d3050..8ef0f7e1 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -855,7 +855,8 @@ consumer_queues(Consumers) -> %% tell the limiter about the number of acks that have been received %% for messages delivered to subscribed consumers, but not acks for -%% messages sent in a response to a basic.get. +%% messages sent in a response to a basic.get (identified by their +%% 'none' consumer tag) notify_limiter(undefined, _Acked) -> ok; notify_limiter(LimiterPid, Acked) -> diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 3776edd0..49a9c195 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -56,8 +56,11 @@ -record(lim, {prefetch_count = 0, ch_pid, - queues = dict:new(), + queues = dict:new(), % QPid -> {MonitorRef, Notify} volume = 0}). +%% 'Notify' is a boolean that indicates whether a queue should be +%% notified of a change in the limit or volume that may allow it to +%% deliver more messages via the limiter's channel. %%---------------------------------------------------------------------------- %% API |