diff --git a/apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl b/apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl index b34228e0d..7a769c5ed 100644 --- a/apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl +++ b/apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl @@ -189,14 +189,14 @@ init_per_group(metrics_fail, Config) -> init_per_group(metrics_simple, Config) -> meck:new(?BRIDGE_IMPL, [non_strict, no_link, passthrough]), meck:expect(?BRIDGE_IMPL, query_mode, fun - (#{mqtt := #{query_mode := sync}}) -> simple_sync; + (#{resource_opts := #{query_mode := sync}}) -> simple_sync; (_) -> simple_async end), [{mecked, [?BRIDGE_IMPL]} | Config]; init_per_group(metrics_fail_simple, Config) -> meck:new(?BRIDGE_IMPL, [non_strict, no_link, passthrough]), meck:expect(?BRIDGE_IMPL, query_mode, fun - (#{mqtt := #{query_mode := sync}}) -> simple_sync; + (#{resource_opts := #{query_mode := sync}}) -> simple_sync; (_) -> simple_async end), meck:expect(?BRIDGE_IMPL, on_query, 3, {error, {unrecoverable_error, mecked_failure}}), @@ -2960,9 +2960,6 @@ do_test_rule_metrics(QMode) -> MsgId = emqx_guid:gen(), emqx:publish(#message{id = MsgId, topic = <<"topic/test">>, payload = <<"hello">>}), timer:sleep(100), - ct:pal("bridge metrics: ~p", [ - emqx_resource:get_metrics(emqx_bridge_resource:resource_id(BridgeId)) - ]), on_exit( fun() -> emqx_rule_engine:delete_rule(RuleId),