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

refactor(rule_engine_metrics): remove function 'message()'

This commit is contained in:
EMQ-YangM 2022-01-05 02:08:40 -08:00
parent c2870b3322
commit e5993c9f72
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl
View File

@ -1369,14 +1369,6 @@ t_metrics(_Config) ->
emqtt:stop(Client), emqtt:stop(Client),
emqx_rule_registry:remove_rule(TopicRule). emqx_rule_registry:remove_rule(TopicRule).
message() ->
<<"{\"date\": \"2020-04-24\",
\"sensors\": [
{\"name\": \"a\", \"idx \":0},
{\"name\": \"b\", \"idx \":1},
{\"name\": \"c\", \"idx \":2}
]}">>.
t_metrics1(_Config) -> t_metrics1(_Config) ->
ok = emqx_rule_engine:load_providers(), ok = emqx_rule_engine:load_providers(),
TopicRule = create_simple_repub_rule( TopicRule = create_simple_repub_rule(
@ -1396,8 +1388,13 @@ t_metrics1(_Config) ->
{ok, _} = emqtt:connect(Client), {ok, _} = emqtt:connect(Client),
ct:sleep(200), ct:sleep(200),
Message = <<"{\"date\": \"2020-04-24\",
emqtt:publish(Client, <<"t1">>, message(), 0), \"sensors\": [
{\"name\": \"a\", \"idx \":0},
{\"name\": \"b\", \"idx \":1},
{\"name\": \"c\", \"idx \":2}
]}">>,
emqtt:publish(Client, <<"t1">>, Message, 0),
ct:sleep(200), ct:sleep(200),
?assertEqual(1, emqx_rule_metrics:get_rules_matched(RuleId)), ?assertEqual(1, emqx_rule_metrics:get_rules_matched(RuleId)),
?assertEqual(1, emqx_rule_metrics:get_rules_passed(RuleId)), ?assertEqual(1, emqx_rule_metrics:get_rules_passed(RuleId)),