diff --git a/apps/emqx_modules/src/emqx_delayed.erl b/apps/emqx_modules/src/emqx_delayed.erl index a57cd9e5e..2e0706cbd 100644 --- a/apps/emqx_modules/src/emqx_delayed.erl +++ b/apps/emqx_modules/src/emqx_delayed.erl @@ -108,7 +108,7 @@ start_link() -> Opts = emqx_config:get([delayed], #{}), gen_server:start_link({local, ?SERVER}, ?MODULE, [Opts], []). --spec(store(#delayed_message{}) -> ok). +-spec(store(#delayed_message{}) -> ok | {error, atom()}). store(DelayedMsg) -> gen_server:call(?SERVER, {store, DelayedMsg}, infinity).