diff options
| -rw-r--r-- | src/rabbit_limiter.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 3f194b318f..e38843c95e 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -27,7 +27,7 @@ start_link(ChPid) -> Pid. set_prefetch_count(LimiterPid, PrefetchCount) -> - gen_server:call(LimiterPid, {prefetch_count, PrefetchCount}). + gen_server:cast(LimiterPid, {prefetch_count, PrefetchCount}). % Queries the limiter to ask whether the queue can deliver a message % without breaching a limit @@ -55,20 +55,20 @@ handle_call({can_send, QPid}, _From, State = #lim{in_use = InUse, false -> NewQueues = sets:add_element(QPid, Queues), {reply, true, State#lim{in_use = InUse + 1, queues = NewQueues}} - end; + end. % When the new limit is larger than the existing limit, % notify all queues and forget about queues with an in-use % capcity of zero -handle_call({prefetch_count, PrefetchCount}, _From, +handle_cast({prefetch_count, PrefetchCount}, State = #lim{prefetch_count = CurrentLimit}) when PrefetchCount > CurrentLimit -> % TODO implement this requirement - {reply, ok, State#lim{prefetch_count = PrefetchCount}}; + {noreply, State#lim{prefetch_count = PrefetchCount}}; % Default setter of the prefetch count -handle_call({prefetch_count, PrefetchCount}, _From, State) -> - {reply, ok, State#lim{prefetch_count = PrefetchCount}}. +handle_cast({prefetch_count, PrefetchCount}, State) -> + {noreply, State#lim{prefetch_count = PrefetchCount}}; % This is an asynchronous ack from a queue that it has received an ack from % a queue. This allows the limiter to update the the in-use-by-that queue |