diff options
| author | David Ansari <david.ansari@gmx.de> | 2021-07-15 20:53:03 +0200 |
|---|---|---|
| committer | David Ansari <david.ansari@gmx.de> | 2021-07-15 20:53:46 +0200 |
| commit | 694804d0d2e7c6620cce879a2dab03c891786f6d (patch) | |
| tree | 5793e226de3d2f066cb3951854bdc645f63c7773 | |
| parent | 3964da37b446c4d430f8254fe801694c3e1d9304 (diff) | |
| download | rabbitmq-server-git-694804d0d2e7c6620cce879a2dab03c891786f6d.tar.gz | |
Add timeout reason to log message
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index c17a307b61..3527643867 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -396,7 +396,9 @@ tuned(info, Msg, StateData) -> end). state_timeout(State, Transport, Socket) -> - rabbit_log_connection:warning("Closing connection because of timeout in state '~s'.", [State]), + rabbit_log_connection:warning( + "Closing connection because of timeout in state '~s' likely due to lack of client action.", + [State]), close_immediately(Transport, Socket), stop. @@ -1004,7 +1006,9 @@ close_sent(state_timeout, close, #statem_data{ connection = #stream_connection{socket = Socket} = Connection, connection_state = State }) -> - rabbit_log_connection:warning("Closing connection because of timeout in state '~s'.", [?FUNCTION_NAME]), + rabbit_log_connection:warning( + "Closing connection because of timeout in state '~s' likely due to lack of client action.", + [?FUNCTION_NAME]), close(Transport, Socket, State), rabbit_networking:unregister_non_amqp_connection(self()), notify_connection_closed(Connection, State), |