From f4eae8c0cb1765e5032c42dd669455a15808d0b4 Mon Sep 17 00:00:00 2001 From: Shawn <506895667@qq.com> Date: Fri, 3 Sep 2021 08:59:00 +0800 Subject: [PATCH] fix(retainer): test case failed for expired retained msg --- ..._protocol_v5_SUITE.erl => emqx_retainer_mqtt_v5_SUITE.erl} | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) rename apps/emqx_retainer/test/{mqtt_protocol_v5_SUITE.erl => emqx_retainer_mqtt_v5_SUITE.erl} (99%) diff --git a/apps/emqx_retainer/test/mqtt_protocol_v5_SUITE.erl b/apps/emqx_retainer/test/emqx_retainer_mqtt_v5_SUITE.erl similarity index 99% rename from apps/emqx_retainer/test/mqtt_protocol_v5_SUITE.erl rename to apps/emqx_retainer/test/emqx_retainer_mqtt_v5_SUITE.erl index cba40de69..0be5df732 100644 --- a/apps/emqx_retainer/test/mqtt_protocol_v5_SUITE.erl +++ b/apps/emqx_retainer/test/emqx_retainer_mqtt_v5_SUITE.erl @@ -14,7 +14,7 @@ %% limitations under the License. %%-------------------------------------------------------------------- --module(mqtt_protocol_v5_SUITE). +-module(emqx_retainer_mqtt_v5_SUITE). -compile(export_all). -compile(nowarn_export_all). @@ -117,7 +117,7 @@ t_publish_message_expiry_interval(_) -> {ok, _} = emqtt:publish(Client1, <<"topic/B">>, #{'Message-Expiry-Interval' => 1}, <<"retained message">>, [{qos, 2}, {retain, true}]), {ok, _} = emqtt:publish(Client1, <<"topic/C">>, #{'Message-Expiry-Interval' => 10}, <<"retained message">>, [{qos, 1}, {retain, true}]), {ok, _} = emqtt:publish(Client1, <<"topic/D">>, #{'Message-Expiry-Interval' => 10}, <<"retained message">>, [{qos, 2}, {retain, true}]), - timer:sleep(1000), + timer:sleep(1500), {ok, _, [2]} = emqtt:subscribe(Client1, <<"topic/+">>, 2), Msgs = receive_messages(4), ?assertEqual(2, length(Msgs)), %% [MQTT-3.3.2-5]