From 7454e46934bd3ba57731ae6df837c3889cca389b Mon Sep 17 00:00:00 2001
From: zhouzb <zhouzb@emqx.io>
Date: Thu, 22 Aug 2019 16:59:13 +0800
Subject: [PATCH] Fix compile error

---
 src/emqx_channel.erl | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/emqx_channel.erl b/src/emqx_channel.erl
index b1671489e..c1ae31e1d 100644
--- a/src/emqx_channel.erl
+++ b/src/emqx_channel.erl
@@ -358,10 +358,10 @@ process_connect(ConnPkt, Channel) ->
 
 %% Process Publish
 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),
     %%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, Msg = #message{qos = ?QOS_0}, Channel) ->