Skip to content

Commit afd0d81

Browse files
Merge pull request #3024 from luos/fix-stuck-mgmt-connections
Link to the connection to avoid stuck unacked messages when using get messages (cherry picked from commit 29f0733)
1 parent 691f729 commit afd0d81

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

deps/rabbitmq_management/src/rabbit_mgmt_util.erl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -953,6 +953,7 @@ with_channel(VHost, ReqData,
953953
virtual_host = VHost},
954954
case amqp_connection:start(Params) of
955955
{ok, Conn} ->
956+
_ = erlang:link(Conn),
956957
{ok, Ch} = amqp_connection:open_channel(Conn),
957958
try
958959
Fun(Ch)
@@ -973,6 +974,7 @@ with_channel(VHost, ReqData,
973974
ServerClose =:= server_initiated_hard_close ->
974975
bad_request_exception(Code, Reason, ReqData, Context)
975976
after
977+
erlang:unlink(Conn),
976978
catch amqp_channel:close(Ch),
977979
catch amqp_connection:close(Conn)
978980
end;

0 commit comments

Comments
 (0)