diff --git a/src/emqttd_mod_rewrite.erl b/src/emqttd_mod_rewrite.erl index 51c96e765..6499a909f 100644 --- a/src/emqttd_mod_rewrite.erl +++ b/src/emqttd_mod_rewrite.erl @@ -46,7 +46,8 @@ load(Opts) -> emqttd_broker:hook('client.unsubscribe', {?MODULE, rewrite_unsubscribe}, {?MODULE, rewrite, [unsubscribe, Sections]}), emqttd_broker:hook('message.publish', {?MODULE, rewrite_publish}, - {?MODULE, rewrite, [publish, Sections]}). + {?MODULE, rewrite, [publish, Sections]}), + {ok, Sections}. rewrite(_ClientId, TopicTable, subscribe, Sections) -> lager:info("rewrite subscribe: ~p", [TopicTable]),