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

Generate packet ID only for QOS > 0 messages.

pull/8/head
Nicolas Jouanin 2015-08-08 22:01:08 +02:00
rodzic 9adbbdfc3a
commit afed8acf72
1 zmienionych plików z 6 dodań i 3 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

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

@ -97,9 +97,12 @@ class ProtocolHandler:
@asyncio.coroutine @asyncio.coroutine
def mqtt_publish(self, topic, message, qos, retain): def mqtt_publish(self, topic, message, qos, retain):
packet_id = self.session.next_packet_id if qos:
if packet_id in self.session.outgoing_msg: packet_id = self.session.next_packet_id
self.logger.warn("%s A message with the same packet ID is already in flight" % self.session.client_id) if packet_id in self.session.outgoing_msg:
self.logger.warn("%s A message with the same packet ID is already in flight" % self.session.client_id)
else:
packet_id = None
packet = PublishPacket.build(topic, message, packet_id, False, qos, retain) packet = PublishPacket.build(topic, message, packet_id, False, qos, retain)
yield from self.outgoing_queue.put(packet) yield from self.outgoing_queue.put(packet)
if qos != QOS_0: if qos != QOS_0: