From e3b5c6be4ea3bb659acbd69e088d404d12d2544d Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 14 Oct 2015 18:56:43 +0800 Subject: [PATCH] PUBLISH_PACKET --- src/emqttd_protocol.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/emqttd_protocol.erl b/src/emqttd_protocol.erl index 9eab5fe14..ce85ddab3 100644 --- a/src/emqttd_protocol.erl +++ b/src/emqttd_protocol.erl @@ -261,12 +261,12 @@ process(?PACKET(?DISCONNECT), State) -> % clean willmsg {stop, normal, State#proto_state{will_msg = undefined}}. -publish(Packet = ?PUBLISH(?QOS_0, _PacketId), +publish(Packet = ?PUBLISH_PACKET(?QOS_0, _PacketId), #proto_state{client_id = ClientId, session = Session}) -> Msg = emqttd_message:from_packet(ClientId, Packet), emqttd_session:publish(Session, Msg); -publish(Packet = ?PUBLISH(?QOS_1, PacketId), +publish(Packet = ?PUBLISH_PACKET(?QOS_1, PacketId), State = #proto_state{client_id = ClientId, session = Session}) -> Msg = emqttd_message:from_packet(ClientId, Packet), case emqttd_session:publish(Session, Msg) of @@ -276,7 +276,7 @@ publish(Packet = ?PUBLISH(?QOS_1, PacketId), lager:error("Client(~s): publish qos1 error - ~p", [ClientId, Error]) end; -publish(Packet = ?PUBLISH(?QOS_2, PacketId), +publish(Packet = ?PUBLISH_PACKET(?QOS_2, PacketId), State = #proto_state{client_id = ClientId, session = Session}) -> Msg = emqttd_message:from_packet(ClientId, Packet), case emqttd_session:publish(Session, Msg) of