diff options
| author | Michael Klishin <michael@rabbitmq.com> | 2013-12-12 12:58:43 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@rabbitmq.com> | 2013-12-12 12:58:43 +0400 |
| commit | 5775931e54d56f5285faeafd4050423409b1cccd (patch) | |
| tree | 58d4bd3514379c89fde4c3bf49374c9737c62559 | |
| parent | b4755059dd271fd7e4c4501425dca1150a5e0d5f (diff) | |
| download | rabbitmq-server-git-5775931e54d56f5285faeafd4050423409b1cccd.tar.gz | |
Decrement channel counter when handling channel.close
| -rw-r--r-- | src/rabbit_reader.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 7d68decf65..7ced87c122 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -330,7 +330,7 @@ handle_other({conserve_resources, Source, Conserve}, handle_other({channel_closing, ChPid}, State) -> ok = rabbit_channel:ready_for_close(ChPid), channel_cleanup(ChPid), - maybe_close(control_throttle(State)); + maybe_close(control_throttle(State#v1{channel_count = (ChannelCount - 1)})); handle_other({'EXIT', Parent, Reason}, State = #v1{parent = Parent}) -> terminate(io_lib:format("broker forced connection closure " "with reason '~w'", [Reason]), State), |