diff --git a/apps/emqx_connector/test/emqx_connector_SUITE.erl b/apps/emqx_connector/test/emqx_connector_SUITE.erl index 5b6d20a40..6b749a3f9 100644 --- a/apps/emqx_connector/test/emqx_connector_SUITE.erl +++ b/apps/emqx_connector/test/emqx_connector_SUITE.erl @@ -53,7 +53,7 @@ init_per_suite(Config) -> emqx_bridge ] ), - + ok = emqx_common_test_helpers:load_config(emqx_connector_schema, <<"connectors: {}">>), Config. end_per_suite(_Config) -> diff --git a/apps/emqx_resource/src/emqx_resource_manager.erl b/apps/emqx_resource/src/emqx_resource_manager.erl index 8edee1c1a..41ff74f16 100644 --- a/apps/emqx_resource/src/emqx_resource_manager.erl +++ b/apps/emqx_resource/src/emqx_resource_manager.erl @@ -18,6 +18,7 @@ -include("emqx_resource.hrl"). -include("emqx_resource_utils.hrl"). +-include_lib("emqx/include/logger.hrl"). % API -export([ @@ -273,7 +274,20 @@ handle_event({call, From}, health_check, stopped, _Data) -> Actions = [{reply, From, {error, stopped}}], {keep_state_and_data, Actions}; handle_event({call, From}, health_check, _State, Data) -> - handle_health_check_event(From, Data). + handle_health_check_event(From, Data); +% Ignore all other events +handle_event(EventType, EventData, State, Data) -> + ?SLOG( + error, + #{ + msg => "ignore all other events", + event_type => EventType, + event_data => EventData, + state => State, + data => Data + } + ), + {next_state, State, Data}. %%------------------------------------------------------------------------------ %% internal functions diff --git a/apps/emqx_resource/test/emqx_resource_SUITE.erl b/apps/emqx_resource/test/emqx_resource_SUITE.erl index d0f6ffd45..0d5230dfa 100644 --- a/apps/emqx_resource/test/emqx_resource_SUITE.erl +++ b/apps/emqx_resource/test/emqx_resource_SUITE.erl @@ -318,7 +318,7 @@ t_create_dry_run_local(_) -> #{name => test_resource, register => true} ) ), - + timer:sleep(100), ?assertEqual(undefined, whereis(test_resource)). t_create_dry_run_local_failed(_) ->