Fix 'function not exported' crash
This commit is contained in:
commit
ba9ea8161e
|
@ -96,7 +96,7 @@ subscribe(Topic, SubId, SubOpts) when is_binary(Topic), ?is_subid(SubId), is_map
|
||||||
SubPid = self(),
|
SubPid = self(),
|
||||||
case ets:member(?SUBOPTION, {SubPid, Topic}) of
|
case ets:member(?SUBOPTION, {SubPid, Topic}) of
|
||||||
false ->
|
false ->
|
||||||
ok = emqx_broker_helper:monitor_sub(SubPid, SubId),
|
ok = emqx_broker_helper:register_sub(SubPid, SubId),
|
||||||
do_subscribe(Topic, SubPid, with_subid(SubId, SubOpts));
|
do_subscribe(Topic, SubPid, with_subid(SubId, SubOpts));
|
||||||
true -> ok
|
true -> ok
|
||||||
end.
|
end.
|
||||||
|
|
Loading…
Reference in New Issue