yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

copy topic_subscriber

This commit is contained in:
Ery Lee 2015-04-09 11:40:05 +08:00
parent 7a979e2c57
commit c0a42b4288
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqttd/src/emqttd_pubsub.erl
View File

@ -245,11 +245,11 @@ init([]) ->
Result1 = Result1 =
mnesia:create_table(topic_subscriber, [ mnesia:create_table(topic_subscriber, [
{type, bag}, {type, bag},
{record_name, topic_subscriber},
{ram_copies, [node()]}, {ram_copies, [node()]},
{attributes, record_info(fields, topic_subscriber)}, {attributes, record_info(fields, topic_subscriber)},
{index, [subpid]}]), {index, [subpid]},
%{local_content, true}]), {local_content, true}]),
mnesia:add_table_copy(topic_subscriber, node(), ram_copies),
mnesia:subscribe({table, topic_subscriber, simple}), mnesia:subscribe({table, topic_subscriber, simple}),
io:format("~p~n", [Result1]), io:format("~p~n", [Result1]),
{ok, #state{}}. {ok, #state{}}.