From 85f0ced88a7add7431c95abc897cfd3e9e39fc0f Mon Sep 17 00:00:00 2001 From: JianBo He Date: Fri, 27 Mar 2020 18:01:00 +0800 Subject: [PATCH] Ensure delayed test case --- test/emqx_mod_delayed_SUITE.erl | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/test/emqx_mod_delayed_SUITE.erl b/test/emqx_mod_delayed_SUITE.erl index b75180e01..99883eb16 100644 --- a/test/emqx_mod_delayed_SUITE.erl +++ b/test/emqx_mod_delayed_SUITE.erl @@ -65,20 +65,16 @@ t_load_case(_) -> ok. t_delayed_message(_) -> - DelayedMsg = emqx_message:make(?MODULE, 1, <<"$delayed/5/publish">>, <<"delayed_m">>), + DelayedMsg = emqx_message:make(?MODULE, 1, <<"$delayed/1/publish">>, <<"delayed_m">>), ?assertEqual({stop, DelayedMsg#message{topic = <<"publish">>, headers = #{allow_publish => false}}}, on_message_publish(DelayedMsg)), - Msg = emqx_message:make(?MODULE, 1, <<"publish">>, <<"delayed_m">>), + Msg = emqx_message:make(?MODULE, 1, <<"no_delayed_msg">>, <<"no_delayed">>), ?assertEqual({ok, Msg}, on_message_publish(Msg)), [Key] = mnesia:dirty_all_keys(emqx_mod_delayed), [#delayed_message{msg = #message{payload = Payload}}] = mnesia:dirty_read({emqx_mod_delayed, Key}), ?assertEqual(<<"delayed_m">>, Payload), - timer:sleep(6000), + timer:sleep(5000), EmptyKey = mnesia:dirty_all_keys(emqx_mod_delayed), - ?assertEqual([], EmptyKey), - %%TODO - %% ExMsg = emqx_message:make(emqx_mod_delayed_SUITE, 1, <<"$delayed/time/publish">>, <<"delayed_message">>), - %% {ok, _} = on_message_publish(ExMsg), - ok. + ?assertEqual([], EmptyKey).