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

Merge pull request #7178 from lafirest/fix/topic_rewrite 

fix(emqx_rewrite): fix config update not work in cluster
This commit is contained in:
JianBo He 2022-03-02 10:14:52 +08:00 committed by GitHub
parent b4439c6710 df2da949f1
commit 480e17ccb5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
apps/emqx_modules/src/emqx_rewrite.erl
View File

@ -37,17 +37,21 @@
]).
-export([ list/0
, update/1]).
, update/1
, post_config_update/5
]).
%%--------------------------------------------------------------------
%% Load/Unload
%%--------------------------------------------------------------------
enable() ->
emqx_conf:add_handler([rewrite], ?MODULE),
Rules = emqx_conf:get([rewrite], []),
register_hook(Rules).
disable() ->
emqx_conf:remove_handler([rewrite]),
emqx_hooks:del('client.subscribe', {?MODULE, rewrite_subscribe}),
emqx_hooks:del('client.unsubscribe', {?MODULE, rewrite_unsubscribe}),
emqx_hooks:del('message.publish', {?MODULE, rewrite_publish}),
@ -57,7 +61,10 @@ list() ->
emqx_conf:get_raw([<<"rewrite">>], []).
update(Rules0) ->
{ok, #{config := Rules}} = emqx_conf:update([rewrite], Rules0, #{override_to => cluster}),
{ok, _} = emqx_conf:update([rewrite], Rules0, #{override_to => cluster}),
ok.
post_config_update(_KeyPath, _Config, Rules, _OldConf, _AppEnvs) ->
register_hook(Rules).
register_hook([]) -> disable();