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

TODO: subscriptions

This commit is contained in:
Feng 2015-12-03 13:14:32 +08:00
parent 80117c1e8a
commit 392b008a43
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
TODO
View File

@ -5,3 +5,9 @@ TODO 2. emqttd_router, emqttd_pubsub to route message
TODO 3. sup, pool_sup, manager...... TODO 3. sup, pool_sup, manager......
TODO 4. route ageing...
TODO 5. dashboard
TODO 6. emqttd_ctl

2
src/emqttd_pubsub.erl
View File

@ -229,7 +229,7 @@ handle_call({subscribe, {SubId, SubPid}, TopicTable}, _From, State) ->
%% Add subscriptions %% Add subscriptions
case mnesia:transaction(fun add_topics/1, [TRecords]) of case mnesia:transaction(fun add_topics/1, [TRecords]) of
{atomic, _} -> {atomic, _} ->
%% store subscription %%TODO: store subscription
%% mnesia:async_dirty(fun add_subscriptions/2, [SubId, TopicTable]), %% mnesia:async_dirty(fun add_subscriptions/2, [SubId, TopicTable]),
{reply, {ok, [Qos || {_Topic, Qos} <- TopicTable]}, State}; {reply, {ok, [Qos || {_Topic, Qos} <- TopicTable]}, State};
{aborted, Error} -> {aborted, Error} ->