Skip to content

Commit d6878f2

Browse files
author
Simon MacMullen
committed
If we get an explicit channel close we might already be shutting the connection down - in which case we should check if we have no more channels left and close_ok the connection if so.
1 parent d3dafe1 commit d6878f2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/rabbit_reader.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,7 @@ handle_other({conserve_memory, Conserve}, Deb, State) ->
281281
handle_other({channel_closing, ChPid}, Deb, State) ->
282282
ok = rabbit_channel:ready_for_close(ChPid),
283283
channel_cleanup(ChPid),
284+
maybe_close(State),
284285
mainloop(Deb, State);
285286
handle_other({'EXIT', Parent, Reason}, _Deb, State = #v1{parent = Parent}) ->
286287
terminate(io_lib:format("broker forced connection closure "

0 commit comments

Comments
 (0)