Ensure expiry_interval expired in testcase
This commit is contained in:
parent
2c07fc310e
commit
a108f292c2
|
@ -55,7 +55,7 @@ message_expiry_interval_exipred(ClientA, QoS) ->
|
||||||
ct:pal("~p ~p", [?FUNCTION_NAME, QoS]),
|
ct:pal("~p ~p", [?FUNCTION_NAME, QoS]),
|
||||||
%% publish to t/a and waiting for the message expired
|
%% publish to t/a and waiting for the message expired
|
||||||
emqtt:publish(ClientA, <<"t/a">>, #{'Message-Expiry-Interval' => 1}, <<"this will be purged in 1s">>, [{qos, QoS}]),
|
emqtt:publish(ClientA, <<"t/a">>, #{'Message-Expiry-Interval' => 1}, <<"this will be purged in 1s">>, [{qos, QoS}]),
|
||||||
ct:sleep(1000),
|
ct:sleep(1500),
|
||||||
|
|
||||||
%% resume the session for client-b
|
%% resume the session for client-b
|
||||||
{ok, ClientB1} = emqtt:start_link([{proto_ver,v5}, {client_id, <<"client-b">>}, {clean_start, false},{properties, #{'Session-Expiry-Interval' => 360}}]),
|
{ok, ClientB1} = emqtt:start_link([{proto_ver,v5}, {client_id, <<"client-b">>}, {clean_start, false},{properties, #{'Session-Expiry-Interval' => 360}}]),
|
||||||
|
|
Loading…
Reference in New Issue