diff --git a/apps/emqx_modules/src/emqx_delayed.erl b/apps/emqx_modules/src/emqx_delayed.erl index 36569d52e..69e9ebb5b 100644 --- a/apps/emqx_modules/src/emqx_delayed.erl +++ b/apps/emqx_modules/src/emqx_delayed.erl @@ -155,7 +155,7 @@ format_delayed(#delayed_message{key = {ExpectTimeStamp, Id}, delayed = Delayed, }, case WithPayload of true -> - Result#{payload => base64:encode(Payload)}; + Result#{payload => Payload}; _ -> Result end. diff --git a/apps/emqx_retainer/src/emqx_retainer_api.erl b/apps/emqx_retainer/src/emqx_retainer_api.erl index b60ac5627..7739d60dc 100644 --- a/apps/emqx_retainer/src/emqx_retainer_api.erl +++ b/apps/emqx_retainer/src/emqx_retainer_api.erl @@ -84,7 +84,7 @@ with_topic_api() -> parameters => parameters(), responses => #{ <<"200">> => object_schema(message_props(), <<"List retained messages">>), - <<"404">> => error_schema(<<"Reatined Not Exists">>, ['NOT_FOUND']), + <<"404">> => error_schema(<<"Retained Not Exists">>, ['NOT_FOUND']), <<"405">> => schema(<<"NotAllowed">>) } },