Merge pull request #11627 from SergeTupchiy/EMQX-10962-fix_hstreamdb-…

…bridge-on-stop fix(emqx_bridge_hstreamdb): fix resources cleanup in on_stop/2 cb
emqx · Sep 18, 2023 · 0b0e322 · 0b0e322
2 parents 45f0d0d + 80cf60e
commit 0b0e322
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl
@@ -48,7 +48,7 @@ on_start(InstId, Config) ->
 
 on_stop(InstId, _State) ->
     case emqx_resource:get_allocated_resources(InstId) of
-        #{client := Client, producer := Producer} ->
+        #{?hstreamdb_client := #{client := Client, producer := Producer}} ->
             StopClientRes = hstreamdb:stop_client(Client),
             StopProducerRes = hstreamdb:stop_producer(Producer),
             ?SLOG(info, #{

diff --git a/changes/ee/fix-11627.en.md b/changes/ee/fix-11627.en.md
@@ -0,0 +1,3 @@
+Fix resources cleanup in HStreamdB bridge.
+
+Prior to this fix, HStreamDB bridge might report errors during bridge configuration updates, since hstreamdb client/producer were not stopped properly.