diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-09-30 15:12:08 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-09-30 15:12:08 +0100 |
| commit | f7d3c443d23599cd252818c18fb153fa098cbca6 (patch) | |
| tree | b3a02b782879d752677040a76fd816f661a4ee5f /src | |
| parent | 65629ae2df29157700b63bd2a988ae4636ecee62 (diff) | |
| download | rabbitmq-server-git-f7d3c443d23599cd252818c18fb153fa098cbca6.tar.gz | |
Don't forget the limiter even if we have no consumers.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index bde11f00e0..f10a50c26c 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -884,7 +884,8 @@ handle_method(#'channel.flow'{active = false}, _, Queues = [{QPid, erlang:monitor(process, QPid)} || QPid <- QPids], ok = rabbit_amqqueue:flush_all(QPids, self()), case Queues of - [] -> {reply, #'channel.flow_ok'{active = false}, State}; + [] -> {reply, #'channel.flow_ok'{active = false}, + State#ch{limiter_pid = LimiterPid1}}; _ -> {noreply, State#ch{limiter_pid = LimiterPid1, blocking = dict:from_list(Queues)}} end; |