From da923c7df04aff0f44d1513fc0335b1aa2798b02 Mon Sep 17 00:00:00 2001 From: JimMoen Date: Wed, 22 Sep 2021 10:39:02 +0800 Subject: [PATCH] fix(delayed): `max-delayed-messages` increase 1 than setting. --- apps/emqx_modules/src/emqx_delayed.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 ->