root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Cosmetic

This commit is contained in:
Ben Hood 2008-12-07 14:43:52 +00:00
parent 48801f251c
commit 5cc6b90a3a
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/amqp_client/src/amqp_network_driver.erl vendored
View File

@ -91,7 +91,8 @@ close_connection(Close = #'connection.close'{}, From,
do(Writer, Method) -> rabbit_writer:send_command(Writer, Method).
do(Writer, Method, Content) -> rabbit_writer:send_command(Writer, Method, Content).
handle_broker_close(#connection_state{channel0_writer_pid = Writer, reader_pid = Reader}) ->
handle_broker_close(#connection_state{channel0_writer_pid = Writer,
reader_pid = Reader}) ->
CloseOk = #'connection.close_ok'{},
rabbit_writer:send_command(Writer, CloseOk),
rabbit_writer:shutdown(Writer),