test(stomp): refine stomp test cases
This commit is contained in:
parent
e4e8590a77
commit
981f74d458
|
@ -100,7 +100,7 @@ t_heartbeat(_) ->
|
||||||
{<<"host">>, <<"127.0.0.1:61613">>},
|
{<<"host">>, <<"127.0.0.1:61613">>},
|
||||||
{<<"login">>, <<"guest">>},
|
{<<"login">>, <<"guest">>},
|
||||||
{<<"passcode">>, <<"guest">>},
|
{<<"passcode">>, <<"guest">>},
|
||||||
{<<"heart-beat">>, <<"1000,800">>}])),
|
{<<"heart-beat">>, <<"1000,2000">>}])),
|
||||||
{ok, Data} = gen_tcp:recv(Sock, 0),
|
{ok, Data} = gen_tcp:recv(Sock, 0),
|
||||||
{ok, #stomp_frame{command = <<"CONNECTED">>,
|
{ok, #stomp_frame{command = <<"CONNECTED">>,
|
||||||
headers = _,
|
headers = _,
|
||||||
|
|
|
@ -35,8 +35,7 @@ t_check_1(_) ->
|
||||||
{ok, HrtBt1} = emqx_stomp_heartbeat:check(incoming, 0, HrtBt),
|
{ok, HrtBt1} = emqx_stomp_heartbeat:check(incoming, 0, HrtBt),
|
||||||
{error, timeout} = emqx_stomp_heartbeat:check(incoming, 0, HrtBt1),
|
{error, timeout} = emqx_stomp_heartbeat:check(incoming, 0, HrtBt1),
|
||||||
|
|
||||||
{ok, HrtBt2} = emqx_stomp_heartbeat:check(outgoing, 0, HrtBt1),
|
{error, timeout} = emqx_stomp_heartbeat:check(outgoing, 0, HrtBt1),
|
||||||
{error, timeout} = emqx_stomp_heartbeat:check(outgoing, 0, HrtBt2),
|
|
||||||
ok.
|
ok.
|
||||||
|
|
||||||
t_check_2(_) ->
|
t_check_2(_) ->
|
||||||
|
|
Loading…
Reference in New Issue