diff options
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 137d13d9ba..6939fbd4ca 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -746,7 +746,7 @@ open(info, open(info, heartbeat_send, #statem_data{ transport = Transport, connection = #stream_connection{socket = S} = Connection, - connection_state = State }) -> + connection_state = State}) -> Frame = rabbit_stream_core:frame(heartbeat), case catch send(Transport, S, Frame) of ok -> @@ -754,17 +754,17 @@ open(info, heartbeat_send, #statem_data{ Unexpected -> rabbit_log_connection:info("Heartbeat send error ~p, closing connection", [Unexpected]), - C1 = demonitor_all_streams(Connection), - close(Transport, C1, State), + _C1 = demonitor_all_streams(Connection), + close(Transport, S, State), stop end; open(info, heartbeat_timeout, #statem_data{ transport = Transport, - connection = Connection, + connection = #stream_connection{socket = S} = Connection, connection_state = State }) -> rabbit_log_connection:debug("Heartbeat timeout, closing connection"), - C1 = demonitor_all_streams(Connection), - close(Transport, C1, State), + _C1 = demonitor_all_streams(Connection), + close(Transport, S, State), stop; open(info, {infos, From}, #statem_data{ connection = #stream_connection{ |