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

mqtt_topic

This commit is contained in:
huangdan 2016-08-21 13:52:53 +08:00
parent 1eaa5bdfa6
commit 7206e18621
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
include/emqttd.hrl
View File

@ -36,6 +36,16 @@
-define(SHARE, <<"$share/">>). %% Shared Topic -define(SHARE, <<"$share/">>). %% Shared Topic
%%--------------------------------------------------------------------
%% MQTT Topic
%%--------------------------------------------------------------------
-record(mqtt_topic, {
topic :: binary(),
flags :: [retained | static]
}).
-type mqtt_topic() :: #mqtt_topic{}.
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% PubSub %% PubSub
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------

2
src/emqttd_router.erl
View File

@ -64,8 +64,6 @@ mnesia(boot) ->
{record_name, mqtt_topic}, {record_name, mqtt_topic},
{attributes, record_info(fields, mqtt_topic)}]); {attributes, record_info(fields, mqtt_topic)}]);
m
mnesia(copy) -> 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). ok = emqttd_mnesia:copy_table(topic).