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

fix(topic-rewrite): better hooks, max priority 1000

This commit is contained in:
DDDHuang 2022-06-24 11:33:01 +08:00
parent 5b62334e89
commit 0092d55b46
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib-ce/emqx_modules/src/emqx_mod_rewrite.erl
View File

@ -45,9 +45,9 @@
load(RawRules) -> load(RawRules) ->
{PubRules, SubRules} = compile(RawRules), {PubRules, SubRules} = compile(RawRules),
emqx_hooks:put('client.subscribe', {?MODULE, rewrite_subscribe, [SubRules]}), emqx_hooks:put('client.subscribe', {?MODULE, rewrite_subscribe, [SubRules]}, 1000),
emqx_hooks:put('client.unsubscribe', {?MODULE, rewrite_unsubscribe, [SubRules]}), emqx_hooks:put('client.unsubscribe', {?MODULE, rewrite_unsubscribe, [SubRules]}, 1000),
emqx_hooks:put('message.publish', {?MODULE, rewrite_publish, [PubRules]}). emqx_hooks:put('message.publish', {?MODULE, rewrite_publish, [PubRules]}, 1000).
rewrite_subscribe(ClientInfo, _Properties, TopicFilters, Rules) -> rewrite_subscribe(ClientInfo, _Properties, TopicFilters, Rules) ->
Binds = fill_client_binds(ClientInfo), Binds = fill_client_binds(ClientInfo),