diff --git a/apps/emqx_web_hook/src/emqx_web_hook_actions.erl b/apps/emqx_web_hook/src/emqx_web_hook_actions.erl index fb63bdabf..f2c03233a 100644 --- a/apps/emqx_web_hook/src/emqx_web_hook_actions.erl +++ b/apps/emqx_web_hook/src/emqx_web_hook_actions.erl @@ -339,8 +339,7 @@ str(Str) when is_list(Str) -> Str; str(Atom) when is_atom(Atom) -> atom_to_list(Atom); str(Bin) when is_binary(Bin) -> binary_to_list(Bin). -pool_opts(Params = #{<<"url">> := URL, - <<"enable_pipelining">> := EnablePipelining}, ResId) -> +pool_opts(Params = #{<<"url">> := URL}, ResId) -> {ok, #{host := Host, port := Port, scheme := Scheme}} = emqx_http_lib:uri_parse(URL), @@ -353,6 +352,7 @@ pool_opts(Params = #{<<"url">> := URL, false -> [] end, TransportOpts = emqx_misc:ipv6_probe(TransportOpts0), + EnablePipelining = maps:get(<<"enable_pipelining">>, Params, true), Opts = case Scheme =:= https of true -> [{transport_opts, TransportOpts}, {transport, ssl}]; false -> [{transport_opts, TransportOpts}]