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

Address review of PR #13996

This commit is contained in:
David Ansari 2025-06-03 13:17:21 +02:00 committed by David Ansari
parent 8e78c102c6
commit 3f6211cda1
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl vendored
View File

@ -2003,7 +2003,7 @@ handle_down({{'DOWN', QName}, _MRef, process, QPid, Reason},
-spec handle_queue_event( -spec handle_queue_event(
{queue_event, rabbit_amqqueue:name() | ?QUEUE_TYPE_QOS_0, term()}, state()) -> {queue_event, rabbit_amqqueue:name() | ?QUEUE_TYPE_QOS_0, term()}, state()) ->
{ok, state()} | {error, Reason :: any(), state()}. {ok, state()} | {error, Reason :: any(), state()}.
handle_queue_event({queue_event, ?QUEUE_TYPE_QOS_0, {queue_down, QName}}, handle_queue_event({queue_event, ?QUEUE_TYPE_QOS_0, {eol, QName}},
State0) -> State0) ->
try handle_queue_down(QName, State0) of try handle_queue_down(QName, State0) of
State -> State ->

2
deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl vendored
View File

@ -127,7 +127,7 @@ delete(Q, _IfUnused, _IfEmpty, ActingUser) ->
case rabbit_amqqueue:internal_delete(Q, ActingUser) of case rabbit_amqqueue:internal_delete(Q, ActingUser) of
ok -> ok ->
Pid = amqqueue:get_pid(Q), Pid = amqqueue:get_pid(Q),
delegate:invoke_no_result([Pid], {gen_server, cast, [{queue_event, ?MODULE, {queue_down, QName}}]}), gen_server:cast(Pid, {queue_event, ?MODULE, {eol, QName}}),
{ok, 0}; {ok, 0};
{error, timeout} = Err -> {error, timeout} = Err ->
Err Err