diff --git a/src/emqttd_pooler.erl b/src/emqttd_pooler.erl index d029b77e6..80fd400aa 100644 --- a/src/emqttd_pooler.erl +++ b/src/emqttd_pooler.erl @@ -53,10 +53,7 @@ start_link() -> %%%============================================================================= -spec start_link(atom(), pos_integer()) -> {ok, pid()} | ignore | {error, any()}. start_link(Pool, Id) -> - gen_server:start_link({local, name(Id)}, ?MODULE, [Pool, Id], []). - -name(Id) -> - list_to_atom(lists:concat([?MODULE, "_", integer_to_list(Id)])). + gen_server:start_link({local, emqttd:reg_name(?MODULE, Id)}, ?MODULE, [Pool, Id], []). %%------------------------------------------------------------------------------ %% @doc Submit work to pooler