summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-11-15 11:57:32 +0000
committerSimon MacMullen <simon@rabbitmq.com>2011-11-15 11:57:32 +0000
commit10c492504c192811f6d30349a3d5d5bc37b60b84 (patch)
treeee4f30f366151c6d07ba6afebe8997048aa13384
parent4818e1ee1a2c2510d03fb7aa53d170290c31b6bd (diff)
downloadrabbitmq-server-bug24560.tar.gz
-rw-r--r--src/rabbit_reader.erl3
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl
index 3c21c210..694abd9e 100644
--- a/src/rabbit_reader.erl
+++ b/src/rabbit_reader.erl
@@ -281,8 +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),
- maybe_close(State),
- 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),