Przeglądaj źródła

Merge pull request #14016 from thalesmg/20241017-m-flush-late-simple-query-responses

fix(buffer worker): flush late replies to simple internal buffer queries
Thales Macedo Garitezi 1 rok temu
rodzic
commit
772d428c82

+ 8 - 1
apps/emqx_resource/src/emqx_resource_buffer_worker.erl

@@ -232,7 +232,14 @@ simple_sync_internal_buffer_query(Id, Request, QueryOpts0) ->
                 end
                 end
         end
         end
     after
     after
-        _ = unalias(ReplyAlias)
+        _ = unalias(ReplyAlias),
+        receive
+            {ReplyAlias, _Response} ->
+                %% stale response
+                ok
+        after 0 ->
+            ok
+        end
     end.
     end.
 
 
 simple_sync_query_opts() ->
 simple_sync_query_opts() ->