diff --git a/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb.app.src b/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb.app.src index 4fd96d5e7..86d2a93b3 100644 --- a/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb.app.src +++ b/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb.app.src @@ -1,7 +1,7 @@ %% -*- mode: erlang -*- {application, emqx_bridge_iotdb, [ {description, "EMQX Enterprise Apache IoTDB Bridge"}, - {vsn, "0.1.5"}, + {vsn, "0.1.6"}, {modules, [ emqx_bridge_iotdb, emqx_bridge_iotdb_connector diff --git a/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb_connector.erl b/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb_connector.erl index d42ccfd71..0090e472a 100644 --- a/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb_connector.erl +++ b/apps/emqx_bridge_iotdb/src/emqx_bridge_iotdb_connector.erl @@ -70,6 +70,8 @@ -import(hoconsc, [mk/2, enum/1, ref/2]). +-dialyzer({no_match, [on_get_channel_status/3]}). + %%------------------------------------------------------------------------------------- %% connector examples %%------------------------------------------------------------------------------------- @@ -372,7 +374,12 @@ on_get_channels(InstanceId) -> emqx_bridge_v2:get_channels_for_connector(InstanceId). on_get_channel_status(InstanceId, _ChannelId, State) -> - on_get_status(InstanceId, State). + case on_get_status(InstanceId, State) of + connected -> + connected; + _ -> + disconnected + end. %%-------------------------------------------------------------------- %% Internal Functions diff --git a/changes/ee/feat-12602.en.md b/changes/ee/feat-12602.en.md new file mode 100644 index 000000000..2a62dfb75 --- /dev/null +++ b/changes/ee/feat-12602.en.md @@ -0,0 +1 @@ +Enhanced health checking for IOTDB connector, using its `ping` API replacing the old method which only validating via a socket connection.