diff --git a/src/emqttd_client.erl b/src/emqttd_client.erl index bd9f16414..ba5203a8f 100644 --- a/src/emqttd_client.erl +++ b/src/emqttd_client.erl @@ -106,15 +106,15 @@ handle_info({stop, duplicate_id, _NewPid}, State=#state{proto_state = ProtoState [emqttd_protocol:clientid(ProtoState), ConnName]), stop({shutdown, duplicate_id}, State); -handle_info({deliver, Message}, #state{proto_state = ProtoState} = State) -> +handle_info({deliver, Message}, State = #state{proto_state = ProtoState}) -> {ok, ProtoState1} = emqttd_protocol:send(Message, ProtoState), {noreply, State#state{proto_state = ProtoState1}}; -handle_info({redeliver, {?PUBREL, PacketId}}, #state{proto_state = ProtoState} = State) -> +handle_info({redeliver, {?PUBREL, PacketId}}, State = #state{proto_state = ProtoState}) -> {ok, ProtoState1} = emqttd_protocol:redeliver({?PUBREL, PacketId}, ProtoState), {noreply, State#state{proto_state = ProtoState1}}; -handle_info({subscribe, TopicTable}, #state{proto_state = ProtoState} = State) -> +handle_info({subscribe, TopicTable}, State = #state{proto_state = ProtoState}) -> {ok, ProtoState1} = emqttd_protocol:handle({subscribe, TopicTable}, ProtoState), {noreply, State#state{proto_state = ProtoState1}}; diff --git a/src/emqttd_ws_client.erl b/src/emqttd_ws_client.erl index c72f46511..2cde114e6 100644 --- a/src/emqttd_ws_client.erl +++ b/src/emqttd_ws_client.erl @@ -127,19 +127,19 @@ handle_cast({received, Packet}, State = #client_state{proto_state = ProtoState}) handle_cast(_Msg, State) -> {noreply, State}. -handle_info({deliver, Message}, #client_state{proto_state = ProtoState} = State) -> +handle_info({deliver, Message}, State = #client_state{proto_state = ProtoState}) -> {ok, ProtoState1} = emqttd_protocol:send(Message, ProtoState), {noreply, State#client_state{proto_state = ProtoState1}}; -handle_info({redeliver, {?PUBREL, PacketId}}, #client_state{proto_state = ProtoState} = State) -> +handle_info({redeliver, {?PUBREL, PacketId}}, State = #client_state{proto_state = ProtoState}) -> {ok, ProtoState1} = emqttd_protocol:redeliver({?PUBREL, PacketId}, ProtoState), {noreply, State#client_state{proto_state = ProtoState1}}; -handle_info({subscribe, TopicTable}, #client_state{proto_state = ProtoState} = State) -> +handle_info({subscribe, TopicTable}, State = #client_state{proto_state = ProtoState}) -> {ok, ProtoState1} = emqttd_protocol:handle({subscribe, TopicTable}, ProtoState), {noreply, State#client_state{proto_state = ProtoState1}}; -handle_info({stop, duplicate_id, _NewPid}, State=#client_state{proto_state = ProtoState}) -> +handle_info({stop, duplicate_id, _NewPid}, State = #client_state{proto_state = ProtoState}) -> lager:error("Shutdown for duplicate clientid: ~s", [emqttd_protocol:clientid(ProtoState)]), stop({shutdown, duplicate_id}, State);