Fix select emqx_shared_subscription fail
This commit is contained in:
parent
94d326f398
commit
36647b641f
|
@ -19,7 +19,7 @@
|
||||||
-include("emqx.hrl").
|
-include("emqx.hrl").
|
||||||
-include("emqx_mqtt.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]).
|
-export([start_link/2, start_bridge/1, stop_bridge/1, status/1]).
|
||||||
|
|
||||||
|
|
|
@ -97,7 +97,7 @@ pick(SubPids) ->
|
||||||
lists:nth((X rem length(SubPids)) + 1, SubPids).
|
lists:nth((X rem length(SubPids)) + 1, SubPids).
|
||||||
|
|
||||||
subscribers(Group, Topic) ->
|
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
|
%% gen_server callbacks
|
||||||
|
|
Loading…
Reference in New Issue