diff --git a/apps/emqx_message_validation/src/emqx_message_validation.erl b/apps/emqx_message_validation/src/emqx_message_validation.erl index d704a2673..364192e58 100644 --- a/apps/emqx_message_validation/src/emqx_message_validation.erl +++ b/apps/emqx_message_validation/src/emqx_message_validation.erl @@ -266,7 +266,7 @@ evaluate_schema_check(Check, Validation, #message{payload = Data}) -> [] end, try - emqx_schema_registry_serde:handle_rule_function(schema_check, [SerdeName, Data | ExtraArgs]) + emqx_schema_registry_serde:schema_check(SerdeName, Data, ExtraArgs) catch error:{serde_not_found, _} -> ?TRACE( diff --git a/apps/emqx_schema_registry/src/emqx_schema_registry_serde.erl b/apps/emqx_schema_registry/src/emqx_schema_registry_serde.erl index 169c686ba..638147fd1 100644 --- a/apps/emqx_schema_registry/src/emqx_schema_registry_serde.erl +++ b/apps/emqx_schema_registry/src/emqx_schema_registry_serde.erl @@ -13,6 +13,7 @@ -export([ make_serde/3, handle_rule_function/2, + schema_check/3, destroy/1 ]).