From 1c748070c115cc668b59f06c959d26a83cd28c1b Mon Sep 17 00:00:00 2001
From: "Zaiming (Stone) Shi" <zmstone@gmail.com>
Date: Thu, 2 Feb 2023 14:01:27 +0100
Subject: [PATCH] fix(emqx_connector_mqtt_worker): publish_async can only
 return ok # Please enter the commit message for your changes. Lines starting

---
 .../src/mqtt/emqx_connector_mqtt_worker.erl               | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl
index 631ac9350..6da63f99a 100644
--- a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl
+++ b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl
@@ -257,12 +257,8 @@ send_to_remote_async(Name, MsgIn, Callback) ->
 
 do_send_async(Name, {true, Msg}, Callback) ->
     Pid = get_pid(Name),
-    case emqtt:publish_async(Pid, Msg, _Timeout = infinity, Callback) of
-        ok ->
-            {ok, Pid};
-        {error, _} = Error ->
-            Error
-    end;
+    ok = emqtt:publish_async(Pid, Msg, _Timeout = infinity, Callback),
+    {ok, Pid};
 do_send_async(_Name, false, _Callback) ->
     ok.