|
|
@@ -57,10 +57,18 @@ mnesia(boot) ->
|
|
|
{type, bag},
|
|
|
{ram_copies, [node()]},
|
|
|
{record_name, mqtt_route},
|
|
|
- {attributes, record_info(fields, mqtt_route)}]);
|
|
|
+ {attributes, record_info(fields, mqtt_route)}]),
|
|
|
+
|
|
|
+ ok = emqttd_mnesia:create_table(topic, [
|
|
|
+ {ram_copies, [node()]},
|
|
|
+ {record_name, mqtt_topic},
|
|
|
+ {attributes, record_info(fields, mqtt_topic)}]);
|
|
|
+
|
|
|
+m
|
|
|
|
|
|
mnesia(copy) ->
|
|
|
- ok = emqttd_mnesia:copy_table(mqtt_route, ram_copies).
|
|
|
+ ok = emqttd_mnesia:copy_table(mqtt_route, ram_copies),
|
|
|
+ ok = emqttd_mnesia:copy_table(topic).
|
|
|
|
|
|
%%--------------------------------------------------------------------
|
|
|
%% Start the Router
|