diff --git a/apps/emqttd/src/emqttd_pubsub.erl b/apps/emqttd/src/emqttd_pubsub.erl index 6e25814cc..eb2bf8565 100644 --- a/apps/emqttd/src/emqttd_pubsub.erl +++ b/apps/emqttd/src/emqttd_pubsub.erl @@ -245,11 +245,11 @@ init([]) -> Result1 = mnesia:create_table(topic_subscriber, [ {type, bag}, - {record_name, topic_subscriber}, {ram_copies, [node()]}, {attributes, record_info(fields, topic_subscriber)}, - {index, [subpid]}]), - %{local_content, true}]), + {index, [subpid]}, + {local_content, true}]), + mnesia:add_table_copy(topic_subscriber, node(), ram_copies), mnesia:subscribe({table, topic_subscriber, simple}), io:format("~p~n", [Result1]), {ok, #state{}}.