Closes #11434

Author: michaelklishin

deps/rabbit/include/amqqueue.hrl

@@ -41,6 +41,9 @@
 -define(amqqueue_is_stream(Q),
         ?amqqueue_type_is(Q, rabbit_stream_queue)).
 
+-define(amqqueue_is_mqtt_qos0(Q),
+    ?amqqueue_type_is(Q, rabbit_mqtt_qos0_queue)).
+
 -define(amqqueue_type_is(Q, Type),
         (?is_amqqueue_v2(Q) andalso
          ?amqqueue_v2_field_type(Q) =:= Type)).

deps/rabbit/src/rabbit_amqqueue.erl

@@ -1346,6 +1346,16 @@ is_unresponsive(Q, Timeout) when ?amqqueue_is_stream(Q) ->
     catch
         exit:{timeout, _} ->
             true
+    end;
+is_unresponsive(Q, Timeout) when ?amqqueue_is_mqtt_qos0(Q) ->
+    QPid = amqqueue:get_pid(Q),
+    try
+        delegate:invoke(QPid, {gen_server2, call, [{info, [name]}, Timeout]}),
+        false
+    catch
+        %% TODO catch any exit??
+        exit:{timeout, _} ->
+            true
     end.
 
 format(Q) ->