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

test: fix flaky test

This commit is contained in:
Thales Macedo Garitezi 2023-01-13 13:50:41 -03:00
parent 30a227bd38
commit 478fcc6ffd
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
apps/emqx_bridge/test/emqx_bridge_mqtt_SUITE.erl
View File

@ -953,18 +953,17 @@ t_mqtt_conn_bridge_egress_reconnect(_) ->
ok.
assert_mqtt_msg_received(Topic, Payload) ->
?assert(
receive
{deliver, Topic, #message{payload = Payload}} ->
ct:pal("Got mqtt message: ~p on topic ~p", [Payload, Topic]),
true;
Msg ->
ct:pal("Unexpected Msg: ~p", [Msg]),
false
after 100 ->
false
end
).
ct:pal("checking if ~p has been received on ~p", [Payload, Topic]),
receive
{deliver, Topic, #message{payload = Payload}} ->
ct:pal("Got mqtt message: ~p on topic ~p", [Payload, Topic]),
ok;
Msg ->
ct:pal("Unexpected Msg: ~p", [Msg]),
assert_mqtt_msg_received(Topic, Payload)
after 100 ->
ct:fail("timeout waiting for ~p on topic ~p", [Payload, Topic])
end.
request(Method, Url, Body) ->
request(<<"connector_admin">>, Method, Url, Body).