diff --git a/deps/amqp_client/src/amqp_network_driver.erl b/deps/amqp_client/src/amqp_network_driver.erl index b8397ee6cc..479815d09e 100644 --- a/deps/amqp_client/src/amqp_network_driver.erl +++ b/deps/amqp_client/src/amqp_network_driver.erl @@ -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),