Skip to content

Commit 72df627

Browse files
committed
Mention socket is from stream reader in log message
1 parent 60be7d8 commit 72df627

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -813,14 +813,14 @@ open(info,
813813
open(info, {Closed, Socket}, #statem_data{connection = Connection})
814814
when Closed =:= tcp_closed; Closed =:= ssl_closed ->
815815
_ = demonitor_all_streams(Connection),
816-
rabbit_log_connection:warning("Socket ~w closed [~w]",
816+
rabbit_log_connection:warning("Stream reader socket ~w closed [~w]",
817817
[Socket, self()]),
818818
stop;
819819
open(info, {Error, Socket, Reason},
820820
#statem_data{connection = Connection})
821821
when Error =:= tcp_error; Error =:= ssl_error ->
822822
_ = demonitor_all_streams(Connection),
823-
rabbit_log_connection:error("Socket error ~tp [~w] [~w]",
823+
rabbit_log_connection:error("Stream reader socket error ~tp [~w] [~w]",
824824
[Reason, Socket, self()]),
825825
stop;
826826
open(info, {'DOWN', MonitorRef, process, _OsirisPid, _Reason},

0 commit comments

Comments
 (0)