diff --git a/apps/emqx_retainer/src/emqx_retainer.app.src b/apps/emqx_retainer/src/emqx_retainer.app.src index 6c0def7ae..5d6fe95f7 100644 --- a/apps/emqx_retainer/src/emqx_retainer.app.src +++ b/apps/emqx_retainer/src/emqx_retainer.app.src @@ -2,7 +2,7 @@ {application, emqx_retainer, [ {description, "EMQX Retainer"}, % strict semver, bump manually! - {vsn, "5.0.19"}, + {vsn, "5.0.20"}, {modules, []}, {registered, [emqx_retainer_sup]}, {applications, [kernel, stdlib, emqx, emqx_ctl]}, diff --git a/apps/emqx_retainer/src/emqx_retainer_api.erl b/apps/emqx_retainer/src/emqx_retainer_api.erl index 5c81bd52e..5aa1b7a31 100644 --- a/apps/emqx_retainer/src/emqx_retainer_api.erl +++ b/apps/emqx_retainer/src/emqx_retainer_api.erl @@ -181,7 +181,6 @@ lookup_retained(get, #{query_string := Qs}) -> Page = maps:get(<<"page">>, Qs, 1), Limit = maps:get(<<"limit">>, Qs, emqx_mgmt:default_row_limit()), Topic = maps:get(<<"topic">>, Qs, undefined), - ct:print("Qs:~p~n", [Qs]), {ok, Msgs} = emqx_retainer_mnesia:page_read(undefined, Topic, Page, Limit), {200, #{ data => [format_message(Msg) || Msg <- Msgs], diff --git a/changes/ce/feat-12272.en.md b/changes/ce/feat-12272.en.md new file mode 100644 index 000000000..b86bdf57d --- /dev/null +++ b/changes/ce/feat-12272.en.md @@ -0,0 +1,3 @@ +Added a new endpoint `DELETE /retainer/messages` to `retain` API to clean all retained messages + +Also added an optional topic filter in the query string for the endpoint "GET /retainer/messages", e.g. "topic=t/1". diff --git a/rel/i18n/emqx_retainer_api.hocon b/rel/i18n/emqx_retainer_api.hocon index f4bd00ae9..87ded1165 100644 --- a/rel/i18n/emqx_retainer_api.hocon +++ b/rel/i18n/emqx_retainer_api.hocon @@ -33,7 +33,7 @@ delete_messages.label: """Delete Retained Messages""" lookup_api.desc: -"""Lookup a message by a topic without wildcards, .""" +"""Lookup a message by a topic without wildcards.""" lookup_api.label: """Lookup a message"""