diff --git a/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl b/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl index d864fd63e4..0e6e698f3a 100644 --- a/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl +++ b/deps/rabbitmq_management_agent/src/rabbit_mgmt_format.erl @@ -538,7 +538,7 @@ clean_consumer_details(Obj) -> case pget(consumer_details, Obj) of undefined -> Obj; Cds -> - Cons = [clean_channel_details(Con) || Con <- Cds], + Cons = [format_consumer_arguments(clean_channel_details(Con)) || Con <- Cds], pset(consumer_details, Cons, Obj) end. @@ -553,6 +553,16 @@ clean_channel_details(Obj) -> Obj0) end. +-spec format_consumer_arguments(proplists:proplist()) -> proplists:proplist(). +format_consumer_arguments(Obj) -> + case pget(arguments, Obj) of + undefined -> Obj; + [] -> Obj; + Args -> pset(arguments, amqp_table(Args), Obj) + end. + +%% Converts a proplist into an AMQP 0-9-1 table. +%% For JSON serialisation formatting see amqp_table/1. args({struct, L}) -> args(L); args(L) -> to_amqp_table(L).