diff --git a/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl b/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl index 62514e314..058d824ac 100644 --- a/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl +++ b/apps/emqx_management/src/emqx_mgmt_api_subscriptions.erl @@ -37,6 +37,7 @@ [ {<<"clientid">>, binary} , {<<"topic">>, binary} , {<<"share">>, binary} + , {<<"share_group">>, binary} , {<<"qos">>, integer} , {<<"match_topic">>, binary}]}). @@ -87,10 +88,10 @@ parameters() -> schema => #{type => integer, enum => [0, 1, 2]} }, #{ - name => share, + name => share_group, in => query, - description => <<"Shared subscription">>, - schema => #{type => boolean} + description => <<"Shared subscription group name">>, + schema => #{type => string} }, #{ name => topic, @@ -183,7 +184,7 @@ update_ms(clientid, X, {{Pid, Topic}, Opts}) -> {{Pid, Topic}, Opts#{subid => X}}; update_ms(topic, X, {{Pid, _Topic}, Opts}) -> {{Pid, X}, Opts}; -update_ms(share, X, {{Pid, Topic}, Opts}) -> +update_ms(share_group, X, {{Pid, Topic}, Opts}) -> {{Pid, Topic}, Opts#{share => X}}; update_ms(qos, X, {{Pid, Topic}, Opts}) -> {{Pid, Topic}, Opts#{qos => X}}.