yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(test): flaky test cases emqx_mod_delayed_SUITE

This commit is contained in:
Shawn 2023-02-17 13:54:54 +08:00
parent 26fecce3b3
commit b0732cb0bb
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib-ce/emqx_modules/test/emqx_mod_delayed_SUITE.erl
View File

@ -58,13 +58,13 @@ set_special_configs(_App) ->
t_load_case(_) -> t_load_case(_) ->
UnHooks = emqx_hooks:lookup('message.publish'), UnHooks = emqx_hooks:lookup('message.publish'),
?assertEqual([], UnHooks), ?assertEqual([], UnHooks),
ok = emqx_mod_delayed:load([]), _ = emqx_mod_delayed:load([]),
Hooks = emqx_hooks:lookup('message.publish'), Hooks = emqx_hooks:lookup('message.publish'),
?assertEqual(1, length(Hooks)), ?assertEqual(1, length(Hooks)),
ok. ok.
t_delayed_message(_) -> t_delayed_message(_) ->
ok = emqx_mod_delayed:load([]), _ = emqx_mod_delayed:load([]),
DelayedMsg = emqx_message:make(?MODULE, 1, <<"$delayed/1/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)), ?assertEqual({stop, DelayedMsg#message{topic = <<"publish">>, headers = #{allow_publish => false}}}, on_message_publish(DelayedMsg)),
@ -81,7 +81,7 @@ t_delayed_message(_) ->
ok = emqx_mod_delayed:unload([]). ok = emqx_mod_delayed:unload([]).
t_banned_delayed(_) -> t_banned_delayed(_) ->
ok = emqx_mod_delayed:load([]), _ = emqx_mod_delayed:load([]),
ClientId1 = <<"bc1">>, ClientId1 = <<"bc1">>,
ClientId2 = <<"bc2">>, ClientId2 = <<"bc2">>,
@ -119,6 +119,7 @@ t_banned_delayed(_) ->
snabbkaffe:stop(), snabbkaffe:stop(),
emqx_banned:delete(Who), emqx_banned:delete(Who),
timer:sleep(500),
EmptyKey = mnesia:dirty_all_keys(emqx_mod_delayed), EmptyKey = mnesia:dirty_all_keys(emqx_mod_delayed),
?assertEqual([], EmptyKey), ?assertEqual([], EmptyKey),
ok = emqx_mod_delayed:unload([]). ok = emqx_mod_delayed:unload([]).