From fa21fa2432c6f34fb66353aef1ccbc324f82fa9f Mon Sep 17 00:00:00 2001 From: EMQ-YangM Date: Fri, 25 Feb 2022 15:25:46 +0800 Subject: [PATCH] fix(emqx_bridge): fix bridge status --- apps/emqx_bridge/src/emqx_bridge_api.erl | 2 +- apps/emqx_bridge/test/emqx_bridge_api_SUITE.erl | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqx_bridge/src/emqx_bridge_api.erl b/apps/emqx_bridge/src/emqx_bridge_api.erl index 330c607c3..27171bd08 100644 --- a/apps/emqx_bridge/src/emqx_bridge_api.erl +++ b/apps/emqx_bridge/src/emqx_bridge_api.erl @@ -423,7 +423,7 @@ aggregate_metrics(AllMetrics) -> format_resp(#{id := Id, raw_config := RawConf, resource_data := #{status := Status, metrics := Metrics}}) -> {Type, BridgeName} = emqx_bridge:parse_bridge_id(Id), - IsConnected = fun(started) -> connected; (_) -> disconnected end, + IsConnected = fun(connected) -> connected; (_) -> disconnected end, RawConf#{ id => Id, type => Type, diff --git a/apps/emqx_bridge/test/emqx_bridge_api_SUITE.erl b/apps/emqx_bridge/test/emqx_bridge_api_SUITE.erl index 09979fe74..dc5129523 100644 --- a/apps/emqx_bridge/test/emqx_bridge_api_SUITE.erl +++ b/apps/emqx_bridge/test/emqx_bridge_api_SUITE.erl @@ -331,7 +331,7 @@ wait_for_resource_ready(InstId, 0) -> ct:fail(wait_resource_timeout); wait_for_resource_ready(InstId, Retry) -> case emqx_bridge:lookup(InstId) of - {ok, #{resource_data := #{status := started}}} -> ok; + {ok, #{resource_data := #{status := connected}}} -> ok; _ -> timer:sleep(100), wait_for_resource_ready(InstId, Retry-1)