chore: update change && bump version
This commit is contained in:
parent
77239da7ed
commit
c3a2cf6220
|
@ -1,7 +1,7 @@
|
||||||
%% -*- mode: erlang -*-
|
%% -*- mode: erlang -*-
|
||||||
{application, emqx_bridge_iotdb, [
|
{application, emqx_bridge_iotdb, [
|
||||||
{description, "EMQX Enterprise Apache IoTDB Bridge"},
|
{description, "EMQX Enterprise Apache IoTDB Bridge"},
|
||||||
{vsn, "0.1.5"},
|
{vsn, "0.1.6"},
|
||||||
{modules, [
|
{modules, [
|
||||||
emqx_bridge_iotdb,
|
emqx_bridge_iotdb,
|
||||||
emqx_bridge_iotdb_connector
|
emqx_bridge_iotdb_connector
|
||||||
|
|
|
@ -70,6 +70,8 @@
|
||||||
|
|
||||||
-import(hoconsc, [mk/2, enum/1, ref/2]).
|
-import(hoconsc, [mk/2, enum/1, ref/2]).
|
||||||
|
|
||||||
|
-dialyzer({no_match, [on_get_channel_status/3]}).
|
||||||
|
|
||||||
%%-------------------------------------------------------------------------------------
|
%%-------------------------------------------------------------------------------------
|
||||||
%% connector examples
|
%% connector examples
|
||||||
%%-------------------------------------------------------------------------------------
|
%%-------------------------------------------------------------------------------------
|
||||||
|
@ -372,7 +374,12 @@ on_get_channels(InstanceId) ->
|
||||||
emqx_bridge_v2:get_channels_for_connector(InstanceId).
|
emqx_bridge_v2:get_channels_for_connector(InstanceId).
|
||||||
|
|
||||||
on_get_channel_status(InstanceId, _ChannelId, State) ->
|
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
|
%% Internal Functions
|
||||||
|
|
|
@ -0,0 +1 @@
|
||||||
|
Enhanced health checking for IOTDB connector, using its `ping` API replacing the old method which only validating via a socket connection.
|
Loading…
Reference in New Issue