yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

misc fix

This commit is contained in:
Ery Lee 2015-01-06 11:50:53 +08:00
parent fdc69f6ea6
commit 1c8ac49b12
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/emqtt/src/emqtt_protocol.erl
View File

@ -112,9 +112,10 @@ handle_request(?CONNECT,
end end
end, end,
lager:info("recv conn...:~p", [ReturnCode]), lager:info("recv conn...:~p", [ReturnCode]),
send_frame(Sock, #mqtt_frame{ fixed = #mqtt_frame_fixed{ type = ?CONNACK}, send_frame(Sock, #mqtt_frame{
variable = #mqtt_frame_connack{ fixed = #mqtt_frame_fixed{ type = ?CONNACK },
return_code = ReturnCode }}), variable = #mqtt_frame_connack{
return_code = ReturnCode }}),
{ok, State1}; {ok, State1};
handle_request(?PUBLISH, Frame=#mqtt_frame{ handle_request(?PUBLISH, Frame=#mqtt_frame{