From 4e767979278a37e46c100355b0a0a9ce0b3bcfba Mon Sep 17 00:00:00 2001 From: Ilya Averyanov Date: Fri, 10 Jun 2022 12:33:27 +0300 Subject: [PATCH] fix(retainer): add additional test --- apps/emqx_retainer/test/emqx_retainer_SUITE.erl | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/apps/emqx_retainer/test/emqx_retainer_SUITE.erl b/apps/emqx_retainer/test/emqx_retainer_SUITE.erl index 100477634..74944f362 100644 --- a/apps/emqx_retainer/test/emqx_retainer_SUITE.erl +++ b/apps/emqx_retainer/test/emqx_retainer_SUITE.erl @@ -220,14 +220,22 @@ t_wildcard_subscription(_) -> <<"this is a retained message 2">>, [{qos, 0}, {retain, true}] ), + emqtt:publish( + C1, + <<"/x/y/z">>, + <<"this is a retained message 3">>, + [{qos, 0}, {retain, true}] + ), {ok, #{}, [0]} = emqtt:subscribe(C1, <<"retained/+">>, 0), {ok, #{}, [0]} = emqtt:subscribe(C1, <<"retained/+/b/#">>, 0), - ?assertEqual(3, length(receive_messages(3))), + {ok, #{}, [0]} = emqtt:subscribe(C1, <<"/+/y/#">>, 0), + ?assertEqual(4, length(receive_messages(4))), emqtt:publish(C1, <<"retained/0">>, <<"">>, [{qos, 0}, {retain, true}]), emqtt:publish(C1, <<"retained/1">>, <<"">>, [{qos, 0}, {retain, true}]), emqtt:publish(C1, <<"retained/a/b/c">>, <<"">>, [{qos, 0}, {retain, true}]), + emqtt:publish(C1, <<"/x/y/z">>, <<"">>, [{qos, 0}, {retain, true}]), ok = emqtt:disconnect(C1). t_message_expiry(_) ->