Skip to content

Commit a58bc89

Browse files
Merge pull request #1918 from rabbitmq/list-queue-type
Add queue type to queue listing commands
2 parents 2f8053d + e576234 commit a58bc89

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

src/rabbit_amqqueue.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -969,6 +969,7 @@ i_down(auto_delete, Q, _) -> amqqueue:is_auto_delete(Q);
969969
i_down(arguments, Q, _) -> amqqueue:get_arguments(Q);
970970
i_down(pid, Q, _) -> amqqueue:get_pid(Q);
971971
i_down(recoverable_slaves, Q, _) -> amqqueue:get_recoverable_slaves(Q);
972+
i_down(type, Q, _) -> amqqueue:get_type(Q);
972973
i_down(state, _Q, DownReason) -> DownReason;
973974
i_down(K, _Q, _DownReason) ->
974975
case lists:member(K, rabbit_amqqueue_process:info_keys()) of

src/rabbit_amqqueue_process.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1128,6 +1128,7 @@ i(reductions, _State) ->
11281128
i(user_who_performed_action, #q{q = Q}) ->
11291129
Opts = amqqueue:get_options(Q),
11301130
maps:get(user, Opts, ?UNKNOWN_USER);
1131+
i(type, _) -> classic;
11311132
i(Item, #q{backing_queue_state = BQS, backing_queue = BQ}) ->
11321133
BQ:info(Item, BQS).
11331134

src/rabbit_quorum_queue.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -967,6 +967,7 @@ i(single_active_consumer_ctag, Q) when ?is_amqqueue(Q) ->
967967
_ ->
968968
''
969969
end;
970+
i(type, _) -> quorum;
970971
i(_K, _Q) -> ''.
971972

972973
open_files(Name) ->

0 commit comments

Comments
 (0)