Add queue type to queue listing commands

[#163984879]

3 files changed, 3 insertions, 0 deletions

diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index 5488a88836..54337311ed 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -969,6 +969,7 @@ i_down(auto_delete,        Q, _) -> amqqueue:is_auto_delete(Q);
 i_down(arguments,          Q, _) -> amqqueue:get_arguments(Q);
 i_down(pid,                Q, _) -> amqqueue:get_pid(Q);
 i_down(recoverable_slaves, Q, _) -> amqqueue:get_recoverable_slaves(Q);
+i_down(type,               Q, _) -> amqqueue:get_type(Q);
 i_down(state, _Q, DownReason)    -> DownReason;
 i_down(K, _Q, _DownReason) ->
     case lists:member(K, rabbit_amqqueue_process:info_keys()) of
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index e1978a9173..e9c091daa0 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -1128,6 +1128,7 @@ i(reductions, _State) ->
 i(user_who_performed_action, #q{q = Q}) ->
     Opts = amqqueue:get_options(Q),
     maps:get(user, Opts, ?UNKNOWN_USER);
+i(type, _) -> classic;
 i(Item, #q{backing_queue_state = BQS, backing_queue = BQ}) ->
     BQ:info(Item, BQS).
 
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl
index c685785d0d..8920c8cf0d 100644
--- a/src/rabbit_quorum_queue.erl
+++ b/src/rabbit_quorum_queue.erl
@@ -967,6 +967,7 @@ i(single_active_consumer_ctag, Q) when ?is_amqqueue(Q) ->
         _ ->
             ''
     end;
+i(type, _) -> quorum;
 i(_K, _Q) -> ''.
 
 open_files(Name) ->