From 392b008a43a2aa23e90a60998dae0477822cc436 Mon Sep 17 00:00:00 2001 From: Feng Date: Thu, 3 Dec 2015 13:14:32 +0800 Subject: [PATCH] TODO: subscriptions --- TODO | 6 ++++++ src/emqttd_pubsub.erl | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/TODO b/TODO index f1fa5239f..9b803822a 100644 --- a/TODO +++ b/TODO @@ -5,3 +5,9 @@ TODO 2. emqttd_router, emqttd_pubsub to route message TODO 3. sup, pool_sup, manager...... +TODO 4. route ageing... + +TODO 5. dashboard + +TODO 6. emqttd_ctl + diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index 1971150de..73058a0b2 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -229,7 +229,7 @@ handle_call({subscribe, {SubId, SubPid}, TopicTable}, _From, State) -> %% Add subscriptions case mnesia:transaction(fun add_topics/1, [TRecords]) of {atomic, _} -> - %% store subscription + %%TODO: store subscription %% mnesia:async_dirty(fun add_subscriptions/2, [SubId, TopicTable]), {reply, {ok, [Qos || {_Topic, Qos} <- TopicTable]}, State}; {aborted, Error} ->