yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: refine async query variable name

This commit is contained in:
JimMoen 2022-08-12 17:28:56 +08:00
parent fa5e8f1422
commit dc7953c3e1
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqx_connector/src/emqx_connector_http.erl
View File

@ -304,7 +304,7 @@ on_query(
end, end,
Result. Result.
on_query_async(InstId, {send_message, Msg}, ReplyFun, State) -> on_query_async(InstId, {send_message, Msg}, ReplyFunAndArgs, State) ->
case maps:get(request, State, undefined) of case maps:get(request, State, undefined) of
undefined -> undefined ->
?SLOG(error, #{msg => "arg_request_not_found", connector => InstId}), ?SLOG(error, #{msg => "arg_request_not_found", connector => InstId}),
@ -320,14 +320,14 @@ on_query_async(InstId, {send_message, Msg}, ReplyFun, State) ->
on_query_async( on_query_async(
InstId, InstId,
{undefined, Method, {Path, Headers, Body}, Timeout}, {undefined, Method, {Path, Headers, Body}, Timeout},
ReplyFun, ReplyFunAndArgs,
State State
) )
end; end;
on_query_async( on_query_async(
InstId, InstId,
{KeyOrNum, Method, Request, Timeout}, {KeyOrNum, Method, Request, Timeout},
ReplyFun, ReplyFunAndArgs,
#{pool_name := PoolName, base_path := BasePath} = State #{pool_name := PoolName, base_path := BasePath} = State
) -> ) ->
?TRACE( ?TRACE(
@ -346,7 +346,7 @@ on_query_async(
Method, Method,
NRequest, NRequest,
Timeout, Timeout,
ReplyFun ReplyFunAndArgs
). ).
on_get_status(_InstId, #{pool_name := PoolName, connect_timeout := Timeout} = State) -> on_get_status(_InstId, #{pool_name := PoolName, connect_timeout := Timeout} = State) ->