mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Internally set packet_id for QOS_0 messages

pull/8/head
Nicolas Jouanin 2015-07-27 15:01:16 +02:00
rodzic 7ce1c62637
commit 54b0383e2f
1 zmienionych plików z 3 dodań i 0 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

3
hbmqtt/mqtt/protocol/handler.py
Wyświetl plik

@ -348,6 +348,9 @@ class ProtocolHandler:
self.logger.warn("[MQTT-3.3.1-2] DUP flag must set to 0 for QOS 0 message. Message ignored: %s" % self.logger.warn("[MQTT-3.3.1-2] DUP flag must set to 0 for QOS 0 message. Message ignored: %s" %
repr(publish_packet)) repr(publish_packet))
else: else:
# Assign packet_id as it's needed internally
packet_id = self.session.next_packet_id
publish_packet.variable_header.packet_id = packet_id
incoming_message = IncomingInFlightMessage(publish_packet, qos) incoming_message = IncomingInFlightMessage(publish_packet, qos)
incoming_message.received_publish() incoming_message.received_publish()
self.session.incoming_msg[packet_id] = incoming_message self.session.incoming_msg[packet_id] = incoming_message