diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-01-13 16:23:54 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-01-13 16:23:54 +0000 |
| commit | e23c5f990d9903eee29acb51979c36e6666ecb94 (patch) | |
| tree | 3317c6226a65c9653bb4ea0dda187b839b843e32 /src | |
| parent | 7edc7cf574ae0f91553c93c01e23b349f07ebe50 (diff) | |
| download | rabbitmq-server-git-e23c5f990d9903eee29acb51979c36e6666ecb94.tar.gz | |
Reinstate a bit of code that accidentally got nuked in 9a87718c74df.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index c8c319ee47..c5e62088e3 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1119,8 +1119,9 @@ handle_method(#'channel.flow'{active = false}, _, ok = rabbit_limiter:block(Limiter1), case consumer_queues(Consumers) of [] -> {reply, #'channel.flow_ok'{active = false}, State1}; - QPids -> ok = rabbit_amqqueue:flush_all(QPids, self()), - {noreply, State1} + QPids -> State2 = State1#ch{blocking = sets:from_list(QPids)}, + ok = rabbit_amqqueue:flush_all(QPids, self()), + {noreply, State2} end; handle_method(_MethodRecord, _Content, _State) -> |