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

fix(emqx_resource): call async reply fun in simple_aysnc_query

This commit is contained in:
Stefan Strigler 2023-06-26 16:46:35 +02:00
parent ae636a52d7
commit 2274a192cc
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_resource/src/emqx_resource_buffer_worker.erl
View File

@ -158,7 +158,9 @@ simple_async_query(Id, Request, QueryOpts0) ->
Ref = make_request_ref(), Ref = make_request_ref(),
Result = call_query(async_if_possible, Id, Index, Ref, ?SIMPLE_QUERY(Request), QueryOpts), Result = call_query(async_if_possible, Id, Index, Ref, ?SIMPLE_QUERY(Request), QueryOpts),
_ = handle_query_result(Id, Result, _HasBeenSent = false), _ = handle_query_result(Id, Result, _HasBeenSent = false),
Result. maybe_apply_async_reply_fun(
Result, QueryOpts
).
simple_query_opts() -> simple_query_opts() ->
ensure_expire_at(#{simple_query => true, timeout => infinity}). ensure_expire_at(#{simple_query => true, timeout => infinity}).