diff --git a/apps/emqx/test/emqx_persistent_messages_SUITE.erl b/apps/emqx/test/emqx_persistent_messages_SUITE.erl index 94bc58908..1a150d5b1 100644 --- a/apps/emqx/test/emqx_persistent_messages_SUITE.erl +++ b/apps/emqx/test/emqx_persistent_messages_SUITE.erl @@ -584,6 +584,8 @@ message(Topic, Payload, PublishedAt) -> id = emqx_guid:gen() }. +on_message_dropped(#message{flags = #{sys := true}}, _Context, _Res, _TestPid) -> + ok; on_message_dropped(Msg, Context, Res, TestPid) -> ErrCtx = #{msg => Msg, ctx => Context, res => Res}, ct:pal("this hook should not be called.\n ~p", [ErrCtx]),