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

Fix compile error

This commit is contained in:
zhouzb 2019-08-22 16:59:13 +08:00
parent 8b03371a4a
commit 7454e46934
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_channel.erl
View File

@ -358,10 +358,10 @@ process_connect(ConnPkt, Channel) ->
%% Process Publish %% Process Publish
process_publish(Packet = ?PUBLISH_PACKET(_QoS, _Topic, PacketId), process_publish(Packet = ?PUBLISH_PACKET(_QoS, _Topic, PacketId),
Channel = #channel{client = Client, proto_ver = ProtoVer}) -> Channel = #channel{client = Client, protocol = Protocol}) ->
Msg = emqx_packet:to_message(Client, Packet), Msg = emqx_packet:to_message(Client, Packet),
%%TODO: Improve later. %%TODO: Improve later.
Msg1 = emqx_message:set_flag(dup, false, emqx_message:set_header(proto_ver, ProtoVer, Msg)), Msg1 = emqx_message:set_flag(dup, false, emqx_message:set_header(proto_ver, emqx_protocol:info(proto_ver, Protocol), Msg)),
process_publish(PacketId, mount(Client, Msg1), Channel). process_publish(PacketId, mount(Client, Msg1), Channel).
process_publish(_PacketId, Msg = #message{qos = ?QOS_0}, Channel) -> process_publish(_PacketId, Msg = #message{qos = ?QOS_0}, Channel) ->