diff --git a/apps/emqx/test/emqx_channel_SUITE.erl b/apps/emqx/test/emqx_channel_SUITE.erl index a30cb33f6..d157cc914 100644 --- a/apps/emqx/test/emqx_channel_SUITE.erl +++ b/apps/emqx/test/emqx_channel_SUITE.erl @@ -580,7 +580,7 @@ t_handle_out_publish_1(_) -> {ok, {outgoing, [?PUBLISH_PACKET(?QOS_1, <<"t">>, 1, <<"payload">>)]}, _Chan} = emqx_channel:handle_out(publish, [{1, Msg}], channel()). -t_handle_out_connack_sucess(_) -> +t_handle_out_connack_success(_) -> {ok, [{event, connected}, {connack, ?CONNACK_PACKET(?RC_SUCCESS, 0, _)}], Channel} = emqx_channel:handle_out(connack, {?RC_SUCCESS, 0, #{}}, channel()), ?assertEqual(connected, emqx_channel:info(conn_state, Channel)). diff --git a/apps/emqx/test/emqx_config_SUITE.erl b/apps/emqx/test/emqx_config_SUITE.erl index 54cc2ee51..4ab34054c 100644 --- a/apps/emqx/test/emqx_config_SUITE.erl +++ b/apps/emqx/test/emqx_config_SUITE.erl @@ -382,7 +382,7 @@ t_init_zone_with_global_defaults(Config) when is_list(Config) -> %% when put zones with global default with emqx_config:put/1 GlobalDefaults = zone_global_defaults(), AllConf = maps:put(zones, Zones, GlobalDefaults), - %% Then put sucess + %% Then put success ?assertEqual(ok, emqx_config:put(AllConf)), %% Then GlobalDefaults are set ?assertEqual(GlobalDefaults, maps:with(maps:keys(GlobalDefaults), emqx_config:get([]))), diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl index 16bca153a..7faa5def9 100644 --- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl +++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl @@ -503,7 +503,7 @@ on_get_status( ) -> %% Note: we must avoid returning `?status_disconnected' here if the connector ever was %% connected. If the connector ever connected, wolff producers might have been - %% sucessfully started, and returning `?status_disconnected' will make resource + %% successfully started, and returning `?status_disconnected' will make resource %% manager try to restart the producers / connector, thus potentially dropping data %% held in wolff producer's replayq. case check_client_connectivity(ClientId) of diff --git a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl index 314afb350..4aeb6e772 100644 --- a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl +++ b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl @@ -347,7 +347,7 @@ parse_dispatch_strategy(#{strategy := Template}) -> %% better distribute the load, effectively making it `random' %% dispatch if the key is absent and we are using `key_dispatch'. %% Otherwise, it'll be deterministic. - emqx_guid:gen(); + emqx_guid:to_base62(emqx_guid:gen()); Key -> Key end diff --git a/apps/emqx_resource/src/emqx_resource_metrics.erl b/apps/emqx_resource/src/emqx_resource_metrics.erl index 243f0edeb..97a09b074 100644 --- a/apps/emqx_resource/src/emqx_resource_metrics.erl +++ b/apps/emqx_resource/src/emqx_resource_metrics.erl @@ -402,7 +402,7 @@ retried_failed_inc(ID, Val) -> retried_failed_get(ID) -> emqx_metrics_worker:get(?RES_METRICS, ID, 'retried.failed'). -%% @doc Count messages that were sucessfully sent after at least one retry +%% @doc Count messages that were successfully sent after at least one retry retried_success_inc(ID) -> retried_success_inc(ID, 1). diff --git a/apps/emqx_rule_engine/src/emqx_rule_events.erl b/apps/emqx_rule_engine/src/emqx_rule_events.erl index d6ed2c5c3..3fb2ba803 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_events.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_events.erl @@ -844,7 +844,7 @@ test_columns('client.connack') -> [ {<<"clientid">>, [<<"c_emqx">>, <<"the clientid if the client">>]}, {<<"username">>, [<<"u_emqx">>, <<"the username if the client">>]}, - {<<"reason_code">>, [<<"sucess">>, <<"the reason code">>]} + {<<"reason_code">>, [<<"success">>, <<"the reason code">>]} ]; test_columns('client.check_authz_complete') -> [ diff --git a/apps/emqx_rule_engine/test/emqx_rule_engine_api_2_SUITE.erl b/apps/emqx_rule_engine/test/emqx_rule_engine_api_2_SUITE.erl index 2c6e91287..f761197f0 100644 --- a/apps/emqx_rule_engine/test/emqx_rule_engine_api_2_SUITE.erl +++ b/apps/emqx_rule_engine/test/emqx_rule_engine_api_2_SUITE.erl @@ -243,7 +243,7 @@ t_rule_test_smoke(_Config) -> #{ <<"clientid">> => <<"c_emqx">>, <<"event_type">> => <<"client_connack">>, - <<"reason_code">> => <<"sucess">>, + <<"reason_code">> => <<"success">>, <<"username">> => <<"u_emqx">> }, <<"sql">> => <<"SELECT\n *\nFROM\n \"t/#\"">> diff --git a/apps/emqx_rule_engine/test/emqx_rule_engine_api_rule_test_SUITE.erl b/apps/emqx_rule_engine/test/emqx_rule_engine_api_rule_test_SUITE.erl index 8b47669da..b13b58df4 100644 --- a/apps/emqx_rule_engine/test/emqx_rule_engine_api_rule_test_SUITE.erl +++ b/apps/emqx_rule_engine/test/emqx_rule_engine_api_rule_test_SUITE.erl @@ -165,7 +165,7 @@ t_ctx_connack(_) -> clean_start => true, clientid => <<"c_emqx">>, event_type => client_connack, - reason_code => <<"sucess">>, + reason_code => <<"success">>, username => <<"u_emqx">> }, Expected = check_result([clientid, username, reason_code], [node], Context),