diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-11-15 15:58:30 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-11-15 15:58:30 +0000 |
| commit | e0be9188019f126f007742c6f213143eb0b47f8a (patch) | |
| tree | 00b40456a358530b36b7b02793a96985452140fe | |
| parent | bb377e3acab155bdf1972fdad12f6fffb1b149e6 (diff) | |
| parent | 10c492504c192811f6d30349a3d5d5bc37b60b84 (diff) | |
| download | rabbitmq-server-e0be9188019f126f007742c6f213143eb0b47f8a.tar.gz | |
Merged bug24560 into default
| -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 b359f7d4..694abd9e 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -281,7 +281,7 @@ handle_other({conserve_memory, Conserve}, Deb, State) -> handle_other({channel_closing, ChPid}, Deb, State) -> ok = rabbit_channel:ready_for_close(ChPid), channel_cleanup(ChPid), - mainloop(Deb, State); + mainloop(Deb, maybe_close(State)); handle_other({'EXIT', Parent, Reason}, _Deb, State = #v1{parent = Parent}) -> terminate(io_lib:format("broker forced connection closure " "with reason '~w'", [Reason]), State), |