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

test(gateway): increase timeout in stomp test case

This commit is contained in:
firest 2022-04-18 17:17:34 +08:00
parent 4368c69a82
commit e5c062582f
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx_gateway/test/emqx_gateway_authz_SUITE.erl
View File

@ -307,12 +307,12 @@ t_case_stomp_subscribe(_) ->
) )
), ),
timer:sleep(100), timer:sleep(200),
Msg = emqx_message:make(Topic, Payload), Msg = emqx_message:make(Topic, Payload),
emqx:publish(Msg), emqx:publish(Msg),
timer:sleep(100), timer:sleep(200),
{ok, Data1} = gen_tcp:recv(Sock, 0, 5000), {ok, Data1} = gen_tcp:recv(Sock, 0, 10000),
{ok, Frame1, _, _} = Mod:parse(Data1), {ok, Frame1, _, _} = Mod:parse(Data1),
Checker(Frame1) Checker(Frame1)
end, end,
@ -406,7 +406,11 @@ t_case_exproto_subscribe(_) ->
%% Helpers %% Helpers
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
try_publish_recv(Topic, Publish, Checker) -> try_publish_recv(Topic, Publish, Checker) ->
try_publish_recv(Topic, Publish, Checker, 500).
try_publish_recv(Topic, Publish, Checker, Timeout) ->
emqx:subscribe(Topic), emqx:subscribe(Topic),
timer:sleep(200),
Clear = fun(Msg) -> Clear = fun(Msg) ->
emqx:unsubscribe(Topic), emqx:unsubscribe(Topic),
Checker(Msg) Checker(Msg)
@ -416,7 +420,7 @@ try_publish_recv(Topic, Publish, Checker) ->
receive receive
{deliver, Topic, Msg} -> {deliver, Topic, Msg} ->
Clear(Msg) Clear(Msg)
after 500 -> after Timeout ->
Clear(timeout) Clear(timeout)
end. end.