fix issue #238 - emqttd_broker:unhook/2 cannot work

This commit is contained in:
Feng Lee 2015-08-12 00:26:10 +08:00
parent f94755166f
commit c4a09f97d5
1 changed files with 5 additions and 4 deletions

View File

@ -246,8 +246,8 @@ handle_call({hook, Hook, Name, MFArgs}, _From, State) ->
end, end,
{reply, Reply, State}; {reply, Reply, State};
handle_call({unhook, Name}, _From, State) -> handle_call({unhook, Hook, Name}, _From, State) ->
Key = {hook, Name}, Reply = Key = {hook, Hook}, Reply =
case ets:lookup(?BROKER_TAB, Key) of case ets:lookup(?BROKER_TAB, Key) of
[{Key, Hooks}] -> [{Key, Hooks}] ->
ets:insert(?BROKER_TAB, {Key, lists:keydelete(Name, 1, Hooks)}); ets:insert(?BROKER_TAB, {Key, lists:keydelete(Name, 1, Hooks)});
@ -256,8 +256,9 @@ handle_call({unhook, Name}, _From, State) ->
end, end,
{reply, Reply, State}; {reply, Reply, State};
handle_call(_Request, _From, State) -> handle_call(Req, _From, State) ->
{reply, {error, unsupport_request}, State}. lager:critical("Unexpected request: ~p", [Req]),
{reply, {error, badreq}, State}.
handle_cast(_Msg, State) -> handle_cast(_Msg, State) ->
{noreply, State}. {noreply, State}.