diff --git a/include/emqttd.hrl b/include/emqttd.hrl index 364c9a28b..57fc55cb6 100644 --- a/include/emqttd.hrl +++ b/include/emqttd.hrl @@ -36,6 +36,16 @@ -define(SHARE, <<"$share/">>). %% Shared Topic +%%-------------------------------------------------------------------- +%% MQTT Topic +%%-------------------------------------------------------------------- +-record(mqtt_topic, { + topic :: binary(), + flags :: [retained | static] + }). + +-type mqtt_topic() :: #mqtt_topic{}. + %%-------------------------------------------------------------------- %% PubSub %%-------------------------------------------------------------------- diff --git a/src/emqttd_router.erl b/src/emqttd_router.erl index 0056d9eb5..d3948a1b6 100644 --- a/src/emqttd_router.erl +++ b/src/emqttd_router.erl @@ -64,8 +64,6 @@ mnesia(boot) -> {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(topic).