diff --git a/apps/emqx_bridge/test/emqx_bridge_mqtt_SUITE.erl b/apps/emqx_bridge/test/emqx_bridge_mqtt_SUITE.erl index 1bb477dad..e2c9382db 100644 --- a/apps/emqx_bridge/test/emqx_bridge_mqtt_SUITE.erl +++ b/apps/emqx_bridge/test/emqx_bridge_mqtt_SUITE.erl @@ -359,9 +359,13 @@ t_mqtt_conn_bridge_egress(_) -> ?assertMatch(<>, Msg#message.from), %% verify the metrics of the bridge - ?assertMetrics( - #{<<"matched">> := 1, <<"success">> := 1, <<"failed">> := 0}, - BridgeIDEgress + ?retry( + _Interval = 200, + _Attempts = 5, + ?assertMetrics( + #{<<"matched">> := 1, <<"success">> := 1, <<"failed">> := 0}, + BridgeIDEgress + ) ), %% delete the bridge @@ -402,9 +406,13 @@ t_mqtt_conn_bridge_egress_no_payload_template(_) -> ?assertMatch(#{<<"payload">> := Payload}, jsx:decode(Msg#message.payload)), %% verify the metrics of the bridge - ?assertMetrics( - #{<<"matched">> := 1, <<"success">> := 1, <<"failed">> := 0}, - BridgeIDEgress + ?retry( + _Interval = 200, + _Attempts = 5, + ?assertMetrics( + #{<<"matched">> := 1, <<"success">> := 1, <<"failed">> := 0}, + BridgeIDEgress + ) ), %% delete the bridge