Merge pull request #405 from emqtt/0.14

Fixed rewrite module
This commit is contained in:
Feng Lee 2015-12-10 22:07:22 +08:00
commit 3dc370b699
1 changed files with 2 additions and 1 deletions

View File

@ -46,7 +46,8 @@ load(Opts) ->
emqttd_broker:hook('client.unsubscribe', {?MODULE, rewrite_unsubscribe}, emqttd_broker:hook('client.unsubscribe', {?MODULE, rewrite_unsubscribe},
{?MODULE, rewrite, [unsubscribe, Sections]}), {?MODULE, rewrite, [unsubscribe, Sections]}),
emqttd_broker:hook('message.publish', {?MODULE, rewrite_publish}, emqttd_broker:hook('message.publish', {?MODULE, rewrite_publish},
{?MODULE, rewrite, [publish, Sections]}). {?MODULE, rewrite, [publish, Sections]}),
{ok, Sections}.
rewrite(_ClientId, TopicTable, subscribe, Sections) -> rewrite(_ClientId, TopicTable, subscribe, Sections) ->
lager:info("rewrite subscribe: ~p", [TopicTable]), lager:info("rewrite subscribe: ~p", [TopicTable]),