diff --git a/apps/emqx_connector/src/emqx_connector_http.erl b/apps/emqx_connector/src/emqx_connector_http.erl index 275b933f7..4891c9595 100644 --- a/apps/emqx_connector/src/emqx_connector_http.erl +++ b/apps/emqx_connector/src/emqx_connector_http.erl @@ -645,7 +645,7 @@ to_bin(Atom) when is_atom(Atom) -> atom_to_binary(Atom, utf8). reply_delegator(Context, ReplyFunAndArgs, Result) -> - maybe_retry(Result, Context, ReplyFunAndArgs). + spawn(fun() -> maybe_retry(Result, Context, ReplyFunAndArgs) end). transform_result(Result) -> case Result of