Skip to content

Commit d632b27

Browse files
michaelklishinmergify[bot]
authored andcommitted
Closes #11434
(cherry picked from commit 18705dd)
1 parent 28181bb commit d632b27

File tree

2 files changed

+13
-0
lines changed

2 files changed

+13
-0
lines changed

deps/rabbit/include/amqqueue.hrl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,9 @@
4141
-define(amqqueue_is_stream(Q),
4242
?amqqueue_type_is(Q, rabbit_stream_queue)).
4343

44+
-define(amqqueue_is_mqtt_qos0(Q),
45+
?amqqueue_type_is(Q, rabbit_mqtt_qos0_queue)).
46+
4447
-define(amqqueue_type_is(Q, Type),
4548
(?is_amqqueue_v2(Q) andalso
4649
?amqqueue_v2_field_type(Q) =:= Type)).

deps/rabbit/src/rabbit_amqqueue.erl

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1409,6 +1409,16 @@ is_unresponsive(Q, Timeout) when ?amqqueue_is_stream(Q) ->
14091409
catch
14101410
exit:{timeout, _} ->
14111411
true
1412+
end;
1413+
is_unresponsive(Q, Timeout) when ?amqqueue_is_mqtt_qos0(Q) ->
1414+
QPid = amqqueue:get_pid(Q),
1415+
try
1416+
delegate:invoke(QPid, {gen_server2, call, [{info, [name]}, Timeout]}),
1417+
false
1418+
catch
1419+
%% TODO catch any exit??
1420+
exit:{timeout, _} ->
1421+
true
14121422
end.
14131423

14141424
format(Q) ->

0 commit comments

Comments
 (0)