Просмотр исходного кода

fix(pulsar): correctly handle timeout during health check

Fixes https://emqx.atlassian.net/browse/EMQX-13402

`pulsar_client:get_status` call actually exits with `{timeout, _}` rather than raising an
error.
Thales Macedo Garitezi 1 год назад
Родитель
Сommit
fa9130fc87

+ 1 - 1
apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar.app.src

@@ -1,6 +1,6 @@
 {application, emqx_bridge_pulsar, [
     {description, "EMQX Pulsar Bridge"},
-    {vsn, "0.2.5"},
+    {vsn, "0.2.6"},
     {registered, []},
     {applications, [
         kernel,

+ 1 - 1
apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_connector.erl

@@ -175,7 +175,7 @@ on_get_status(_InstanceId, State = #{}) ->
                 true -> ?status_connected;
                 false -> ?status_connecting
             catch
-                error:timeout ->
+                exit:{timeout, _} ->
                     ?status_connecting;
                 exit:{noproc, _} ->
                     ?status_connecting

Разница между файлами не показана из-за своего большого размера
+ 5 - 0
changes/ee/fix-14120.en.md