diff --git a/src/emqx_bridge1.erl b/src/emqx_bridge1.erl index 139711932..cfad74803 100644 --- a/src/emqx_bridge1.erl +++ b/src/emqx_bridge1.erl @@ -19,7 +19,7 @@ -include("emqx.hrl"). -include("emqx_mqtt.hrl"). - -import(proplists, [get_value/2, get_value/3]). +-import(proplists, [get_value/2, get_value/3]). -export([start_link/2, start_bridge/1, stop_bridge/1, status/1]). diff --git a/src/emqx_shared_sub.erl b/src/emqx_shared_sub.erl index 2e4772f05..5194de9d4 100644 --- a/src/emqx_shared_sub.erl +++ b/src/emqx_shared_sub.erl @@ -97,7 +97,7 @@ pick(SubPids) -> lists:nth((X rem length(SubPids)) + 1, SubPids). subscribers(Group, Topic) -> - ets:select(?TAB, [{{shared_subscription, Group, Topic, '$1'}, [], ['$1']}]). + ets:select(?TAB, [{{emqx_shared_subscription, Group, Topic, '$1'}, [], ['$1']}]). %%----------------------------------------------------------------------------- %% gen_server callbacks