From 85be3eef4924dd82e0d052f62251d7b4bf9ef1d3 Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Wed, 14 Jan 2015 13:34:07 +0800 Subject: [PATCH] stop when badmsg, badinfo --- apps/emqtt/src/emqtt_session.erl | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/apps/emqtt/src/emqtt_session.erl b/apps/emqtt/src/emqtt_session.erl index 20334ac93..b25667b0a 100644 --- a/apps/emqtt/src/emqtt_session.erl +++ b/apps/emqtt/src/emqtt_session.erl @@ -184,8 +184,8 @@ handle_call({unsubscribe, Topics}, _From, State) -> {ok, NewState} = unsubscribe(State, Topics), {reply, ok, NewState}; -handle_call(_Request, _From, State) -> - {reply, ok, State}. +handle_call(Req, _From, State) -> + {stop, {badreq, Req}, State}. handle_cast({publish, ?QOS_2, Message}, State) -> NewState = publish(State, {?QOS_2, Message}), @@ -210,8 +210,8 @@ handle_cast({pubcomp, PacketId}, State) -> handle_cast(Msg, State) -> {stop, {badmsg, Msg}, State}. -handle_info(_Info, State) -> - {noreply, State}. +handle_info(Info, State) -> + {stop, {badinfo, Info}, State}. terminate(_Reason, _State) -> ok. @@ -224,4 +224,3 @@ code_change(_OldVsn, State, _Extra) -> %% ------------------------------------------------------------------ -