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

fix: delayed math string (#5609) 

* fix: delayed ms
This commit is contained in:
DDDHuang 2021-08-31 19:04:38 +08:00 committed by GitHub
parent 7e53469bb8
commit 4c468b383a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/emqx_modules/src/emqx_delayed.erl
View File

@ -52,6 +52,10 @@
-record(delayed_message, {key, delayed, msg}). -record(delayed_message, {key, delayed, msg}).
%% sync ms with record change
-define(QUERY_MS(Id), [{{delayed_message, {'_', Id}, '_', '_'}, [], ['$_']}]).
-define(DELETE_MS(Id), [{{delayed_message, {'$1', Id}, '_', '_'}, [], ['$1']}]).
-define(TAB, ?MODULE). -define(TAB, ?MODULE).
-define(SERVER, ?MODULE). -define(SERVER, ?MODULE).
-define(MAX_INTERVAL, 4294967). -define(MAX_INTERVAL, 4294967).
@ -161,8 +165,7 @@ to_rfc3339(Timestamp) ->
get_delayed_message(Id0) -> get_delayed_message(Id0) ->
Id = emqx_guid:from_hexstr(Id0), Id = emqx_guid:from_hexstr(Id0),
Ms = [{{delayed_message,{'_',Id},'_'},[],['$_']}], case ets:select(?TAB, ?QUERY_MS(Id)) of
case ets:select(?TAB, Ms) of
[] -> [] ->
{error, not_found}; {error, not_found};
Rows -> Rows ->
@ -172,8 +175,7 @@ get_delayed_message(Id0) ->
delete_delayed_message(Id0) -> delete_delayed_message(Id0) ->
Id = emqx_guid:from_hexstr(Id0), Id = emqx_guid:from_hexstr(Id0),
Ms = [{{delayed_message, {'$1', Id}, '_'}, [], ['$1']}], case ets:select(?TAB, ?DELETE_MS(Id)) of
case ets:select(?TAB, Ms) of
[] -> [] ->
{error, not_found}; {error, not_found};
Rows -> Rows ->