chore(gw): ignore auto-subscribe msg
This commit is contained in:
parent
ffacfe9664
commit
20e3b721a8
|
@ -423,6 +423,9 @@ handle_info({hreply, FunName, ok}, Channel)
|
|||
handle_info({hreply, FunName, {error, Reason}}, Channel) ->
|
||||
{shutdown, {error, {FunName, Reason}}, Channel};
|
||||
|
||||
handle_info({subscribe, _}, Channel) ->
|
||||
{ok, Channel};
|
||||
|
||||
handle_info(Info, Channel) ->
|
||||
?SLOG(warning, #{ msg => "unexpected_info"
|
||||
, info => Info
|
||||
|
|
|
@ -1296,6 +1296,9 @@ handle_info(clean_authz_cache, Channel) ->
|
|||
ok = emqx_authz_cache:empty_authz_cache(),
|
||||
{ok, Channel};
|
||||
|
||||
handle_info({subscribe, _}, Channel) ->
|
||||
{ok, Channel};
|
||||
|
||||
handle_info(Info, Channel) ->
|
||||
?SLOG(error, #{ msg => "unexpected_info"
|
||||
, info => Info
|
||||
|
|
|
@ -777,6 +777,9 @@ handle_info(clean_authz_cache, Channel) ->
|
|||
ok = emqx_authz_cache:empty_authz_cache(),
|
||||
{ok, Channel};
|
||||
|
||||
handle_info({subscribe, _}, Channel) ->
|
||||
{ok, Channel};
|
||||
|
||||
handle_info(Info, Channel) ->
|
||||
?SLOG(error, #{ msg => "unexpected_info"
|
||||
, info => Info
|
||||
|
|
|
@ -15,10 +15,11 @@
|
|||
%%--------------------------------------------------------------------
|
||||
-module(emqx_event_message_api).
|
||||
|
||||
-include("emqx_modules.hrl").
|
||||
|
||||
-behaviour(minirest_api).
|
||||
|
||||
-import(hoconsc, [mk/2, ref/2]).
|
||||
-include("emqx_modules.hrl").
|
||||
|
||||
-export([ api_spec/0
|
||||
, paths/0
|
||||
|
|
Loading…
Reference in New Issue