Remove rabbit_stream:kill_connection/1

This function was not called from anywhere
and was the only place that expected stream
connections to be registered in pg_local.

Author: mkuratczyk

deps/rabbitmq_stream/src/rabbit_stream.erl

@@ -22,8 +22,7 @@
          host/0,
          tls_host/0,
          port/0,
-         tls_port/0,
-         kill_connection/1]).
+         tls_port/0]).
 -export([stop/1]).
 -export([emit_connection_info_local/3,
          emit_connection_info_all/4,
@@ -132,20 +131,6 @@ tls_port_from_listener() ->
 stop(_State) ->
     ok.
 
-kill_connection(ConnectionName) ->
-    ConnectionNameBin = rabbit_data_coercion:to_binary(ConnectionName),
-    lists:foreach(fun(ConnectionPid) ->
-                     ConnectionPid ! {infos, self()},
-                     receive
-                         {ConnectionPid,
-                          #{<<"connection_name">> := ConnectionNameBin}} ->
-                             exit(ConnectionPid, kill);
-                         {ConnectionPid, _ClientProperties} -> ok
-                     after 1000 -> ok
-                     end
-                  end,
-                  pg_local:get_members(rabbit_stream_connections)).
-
 emit_connection_info_all(Nodes, Items, Ref, AggregatorPid) ->
     Pids =
         [spawn_link(Node,

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

@@ -470,10 +470,6 @@ transition_to_opened(Transport,
                      Configuration,
                      NewConnection,
                      NewConnectionState) ->
-    % TODO remove registration to rabbit_stream_connections
-    % just meant to be able to close the connection remotely
-    % should be possible once the connections are available in ctl list_connections
-    pg_local:join(rabbit_stream_connections, self()),
     Connection1 =
         rabbit_event:init_stats_timer(NewConnection,
                                       #stream_connection.stats_timer),