root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Support shutdown call from management plugin

This commit is contained in:
Arnaud Cogoluègnes 2020-10-23 11:14:04 +02:00
parent bd191cf40d
commit a2f05f5b75
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
deps/rabbitmq_stream/src/rabbit_stream_reader.erl vendored
View File

@ -396,6 +396,15 @@ listen_loop_post_auth(Transport, #stream_connection{socket = S,
rabbit_event:notify(connection_created, Infos, Ref),
Connection1 = rabbit_event:init_stats_timer(Connection, #stream_connection.stats_timer),
listen_loop_post_auth(Transport, Connection1, State, Configuration);
{'$gen_call', From, {shutdown, Explanation}} ->
% likely closing call from the management plugin
gen_server:reply(From, ok),
rabbit_log:info("Forcing stream connection ~p closing: ~p~n", [self(), Explanation]),
demonitor_all_streams(Connection),
rabbit_networking:unregister_external_connection(self()),
notify_connection_closed(Connection, State),
close(Transport, S),
ok;
{Closed, S} ->
demonitor_all_streams(Connection),
rabbit_networking:unregister_external_connection(self()),