From c4a09f97d5006f80a723dabfb6d1db4d983c5749 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 12 Aug 2015 00:26:10 +0800 Subject: [PATCH] fix issue #238 - emqttd_broker:unhook/2 cannot work --- src/emqttd_broker.erl | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/emqttd_broker.erl b/src/emqttd_broker.erl index 9b002711e..2b1210221 100644 --- a/src/emqttd_broker.erl +++ b/src/emqttd_broker.erl @@ -246,8 +246,8 @@ handle_call({hook, Hook, Name, MFArgs}, _From, State) -> end, {reply, Reply, State}; -handle_call({unhook, Name}, _From, State) -> - Key = {hook, Name}, Reply = +handle_call({unhook, Hook, Name}, _From, State) -> + Key = {hook, Hook}, Reply = case ets:lookup(?BROKER_TAB, Key) of [{Key, Hooks}] -> ets:insert(?BROKER_TAB, {Key, lists:keydelete(Name, 1, Hooks)}); @@ -256,8 +256,9 @@ handle_call({unhook, Name}, _From, State) -> end, {reply, Reply, State}; -handle_call(_Request, _From, State) -> - {reply, {error, unsupport_request}, State}. +handle_call(Req, _From, State) -> + lager:critical("Unexpected request: ~p", [Req]), + {reply, {error, badreq}, State}. handle_cast(_Msg, State) -> {noreply, State}.