diff --git a/apps/emqx_modules/src/emqx_delayed.erl b/apps/emqx_modules/src/emqx_delayed.erl index 823424c1f..8a8011575 100644 --- a/apps/emqx_modules/src/emqx_delayed.erl +++ b/apps/emqx_modules/src/emqx_delayed.erl @@ -206,9 +206,9 @@ handle_call({store, DelayedMsg = #delayed_message{key = Key}}, {reply, ok, ensure_publish_timer(Key, State)}; handle_call({store, DelayedMsg = #delayed_message{key = Key}}, - _From, State = #{max_delayed_messages := Val}) -> + _From, State = #{max_delayed_messages := Max}) -> Size = mnesia:table_info(?TAB, size), - case Size > Val of + case Size >= Max of true -> {reply, {error, max_delayed_messages_full}, State}; false ->