use connection domain

Author: kjnilsson

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

@@ -1007,7 +1007,7 @@ open(cast,
                                                                 SendFileOct)
                                                of
                                                    {error, closed} ->
-                                                       rabbit_log:info("Stream protocol connection has been closed by peer", []),
+                                                       rabbit_log_connection:info("Stream protocol connection has been closed by peer", []),
                                                        throw({stop, normal});
                                                    {error, Reason} ->
                                                        rabbit_log_connection:info("Error while sending chunks: ~p",
@@ -1825,7 +1825,7 @@ handle_frame_post_auth(Transport,
 
                             case send_chunks(Transport, ConsumerState, SendFileOct) of
                                 {error, closed} ->
-                                    rabbit_log:info("Stream protocol connection has been closed by peer", []),
+                                    rabbit_log_connection:info("Stream protocol connection has been closed by peer", []),
                                     throw({stop, normal});
                                 {{segment, Segment1}, {credit, Credit1}} ->
                                     ConsumerState1 =
@@ -1900,7 +1900,7 @@ handle_frame_post_auth(Transport,
                              SendFileOct)
             of
                 {error, closed} ->
-                    rabbit_log:info("Stream protocol connection has been closed by peer", []),
+                    rabbit_log_connection:info("Stream protocol connection has been closed by peer", []),
                     throw({stop, normal});
                 {{segment, Segment1}, {credit, Credit1}} ->
                     Consumer1 =