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

Merge pull request #7376 from lafirest/fix/flaky_test 

fix(mod_subscription): fix test case error
This commit is contained in:
JianBo He 2022-03-23 18:37:24 +08:00 committed by GitHub
parent 0a98086329 a2085555e9
commit 0309302c42
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib-ce/emqx_modules/test/emqx_mod_subscription_SUITE.erl
View File

@ -60,7 +60,7 @@ t_suboption(_) ->
Client_info = fun(Key, Client) -> maps:get(Key, maps:from_list(emqtt:info(Client)), undefined) end, Client_info = fun(Key, Client) -> maps:get(Key, maps:from_list(emqtt:info(Client)), undefined) end,
Suboption = #{qos => ?QOS_2, nl => 1, rap => 1, rh => 2}, Suboption = #{qos => ?QOS_2, nl => 1, rap => 1, rh => 2},
?assertEqual(ok, emqx_mod_subscription:load([{<<"connected/%c/%u">>, Suboption}])), ?assertEqual(ok, emqx_mod_subscription:load([{<<"connected/%c/%u">>, Suboption}])),
{ok, C1} = emqtt:start_link([{proto_ver, v5}]), {ok, C1} = emqtt:start_link([{proto_ver, v5}, {username, "admin"}]),
{ok, _} = emqtt:connect(C1), {ok, _} = emqtt:connect(C1),
timer:sleep(200), timer:sleep(200),
[CPid1] = emqx_cm:lookup_channels(Client_info(clientid, C1)), [CPid1] = emqx_cm:lookup_channels(Client_info(clientid, C1)),
@ -69,7 +69,7 @@ t_suboption(_) ->
?assertMatch({Sub1, #{qos := 2, nl := 1, rap := 1, rh := 2, subid := _}}, Suboption1), ?assertMatch({Sub1, #{qos := 2, nl := 1, rap := 1, rh := 2, subid := _}}, Suboption1),
ok = emqtt:disconnect(C1), ok = emqtt:disconnect(C1),
%% The subscription option is not valid for MQTT V3.1.1 %% The subscription option is not valid for MQTT V3.1.1
{ok, C2} = emqtt:start_link([{proto_ver, v4}]), {ok, C2} = emqtt:start_link([{proto_ver, v4}, {username, "admin"}]),
{ok, _} = emqtt:connect(C2), {ok, _} = emqtt:connect(C2),
timer:sleep(200), timer:sleep(200),
[CPid2] = emqx_cm:lookup_channels(Client_info(clientid, C2)), [CPid2] = emqx_cm:lookup_channels(Client_info(clientid, C2)),