From 99872b253fd2a64c60902143c166890706f184d0 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 12 Dec 2018 14:53:22 +0800 Subject: [PATCH] Fix 'function not exported' crash --- src/emqx_broker.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqx_broker.erl b/src/emqx_broker.erl index 9ed4aad06..105589c65 100644 --- a/src/emqx_broker.erl +++ b/src/emqx_broker.erl @@ -96,7 +96,7 @@ subscribe(Topic, SubId, SubOpts) when is_binary(Topic), ?is_subid(SubId), is_map SubPid = self(), case ets:member(?SUBOPTION, {SubPid, Topic}) of 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)); true -> ok end.