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

test: assert message receive pid is in the expected pids list

This commit is contained in:
Zaiming (Stone) Shi 2022-10-19 18:16:38 +02:00
parent 27de9998a8
commit b3ffe89f35
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqx/test/emqx_shared_sub_SUITE.erl
View File

@ -465,7 +465,7 @@ last_message(ExpectedPayload, Pids) ->
last_message(ExpectedPayload, Pids, Timeout) -> last_message(ExpectedPayload, Pids, Timeout) ->
receive receive
{publish, #{client_pid := Pid, payload := ExpectedPayload}} -> {publish, #{client_pid := Pid, payload := ExpectedPayload}} ->
ct:pal("~p ====== ~p", [Pids, Pid]), ?assert(lists:member(Pid, Pids)),
{true, Pid} {true, Pid}
after Timeout -> after Timeout ->
ct:pal("not yet"), ct:pal("not yet"),
@ -864,9 +864,9 @@ t_session_takeover(Config) when is_list(Config) ->
{ok, _} = emqtt:connect(ConnPid2), {ok, _} = emqtt:connect(ConnPid2),
?assertMatch([_], emqx:publish(Message3)), ?assertMatch([_], emqx:publish(Message3)),
?assertMatch([_], emqx:publish(Message4)), ?assertMatch([_], emqx:publish(Message4)),
{true, _} = last_message(<<"hello2">>, [ConnPid1]), {true, _} = last_message(<<"hello2">>, [ConnPid2]),
{true, _} = last_message(<<"hello3">>, [ConnPid1]), {true, _} = last_message(<<"hello3">>, [ConnPid2]),
{true, _} = last_message(<<"hello4">>, [ConnPid1]), {true, _} = last_message(<<"hello4">>, [ConnPid2]),
?assertEqual([], collect_msgs(timer:seconds(2))), ?assertEqual([], collect_msgs(timer:seconds(2))),
emqtt:stop(ConnPid2), emqtt:stop(ConnPid2),
ok. ok.