From 48255915655ebcefb06d2d6436a591624d295028 Mon Sep 17 00:00:00 2001 From: Feng Date: Mon, 12 Oct 2015 21:06:01 +0800 Subject: [PATCH] name --- src/emqttd_pubsub.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index 6bb32452c..478db721d 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -107,7 +107,10 @@ mnesia(copy) -> Id :: pos_integer(), Opts :: list(). start_link(Id, Opts) -> - gen_server2:start_link(?MODULE, [Id, Opts], []). + gen_server2:start_link({local, name(Id)}, ?MODULE, [Id, Opts], []). + +name(Id) -> + list_to_atom("emqttd_pubsub_" ++ integer_to_list(Id)). %%------------------------------------------------------------------------------ %% @doc Create topic. Notice That this transaction is not protected by pubsub pool