diff --git a/apps/emqx_modules/src/emqx_modules_schema.erl b/apps/emqx_modules/src/emqx_modules_schema.erl index 99e0b4860..a7c6c2952 100644 --- a/apps/emqx_modules/src/emqx_modules_schema.erl +++ b/apps/emqx_modules/src/emqx_modules_schema.erl @@ -43,10 +43,16 @@ fields("delayed") -> ]; fields("rewrite") -> - [ {action, sc(hoconsc:enum([subscribe, publish, all]), #{desc => "Action", example => publish})} - , {source_topic, sc(binary(), #{desc => "Origin Topic", example => "x/#"})} - , {dest_topic, sc(binary(), #{desc => "Destination Topic", example => "z/y/$1"})} - , {re, fun regular_expression/1 } + [ { action + , sc( hoconsc:enum([subscribe, publish, all]) + , #{desc => <<"Action">>, example => publish})} + , { source_topic + , sc( binary() + , #{desc => <<"Origin Topic">>, example => "x/#"})} + , { dest_topic + , sc( binary() + , #{desc => <<"Destination Topic">>, example => "z/y/$1"})} + , { re, fun regular_expression/1 } ];