summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_channel.erl3
-rw-r--r--src/rabbit_limiter.erl5
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