From ba897e51f9f27de998ba638c69d65c33b8578ce1 Mon Sep 17 00:00:00 2001 From: turtled Date: Sat, 8 Dec 2018 10:26:50 +0800 Subject: [PATCH] Subscriber down clear emqx_suboption table --- src/emqx_broker.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/emqx_broker.erl b/src/emqx_broker.erl index 380e16c42..5f3e63059 100644 --- a/src/emqx_broker.erl +++ b/src/emqx_broker.erl @@ -272,7 +272,8 @@ subscriber_down(SubPid) -> I -> true = ets:delete_object(?SUBSCRIBER, {Topic, {shared, I}}), true = ets:delete_object(?SUBSCRIBER, {{shared, Topic, I}, SubPid}), ok = cast(pick({Topic, I}), {unsubscribed, Topic, I}) - end; + end, + ets:delete(?SUBOPTION, Sub); [] -> ok end end, ets:lookup(?SUBSCRIPTION, SubPid)),