|
|
@@ -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}]
|