diff --git a/apps/emqx/src/emqx_broker.erl b/apps/emqx/src/emqx_broker.erl index 7dd3d08be..ac9116cbd 100644 --- a/apps/emqx/src/emqx_broker.erl +++ b/apps/emqx/src/emqx_broker.erl @@ -621,10 +621,10 @@ sync_route(Action, Topic, ReplyTo) -> none -> regular_sync_route(Action, Topic); Role -> - case mria_config:whoami() of - Role -> + case Role =:= mria_config:whoami() of + true -> push_sync_route(Action, Topic, ReplyTo); - _Disabled -> + false -> regular_sync_route(Action, Topic) end end.