pull/8/head
Nico 2015-09-27 21:17:28 +02:00
rodzic 8bafbeb0f2
commit cbf86e9605
2 zmienionych plików z 0 dodań i 10 usunięć

Wyświetl plik

@ -403,15 +403,6 @@ class ProtocolHandler:
self.logger.debug("Delivering message %s" % message)
return message
@asyncio.coroutine
def mqtt_acknowledge_delivery(self, packet_id):
try:
message = self.session.inflight_in[packet_id]
message.acknowledge_delivery()
self.logger.debug('Message delivery acknowledged, packed_id=%d' % packet_id)
except KeyError:
pass
def handle_write_timeout(self):
self.logger.debug('%s write timeout unhandled' % self.session.client_id)

Wyświetl plik

@ -27,7 +27,6 @@ def uptime_coro():
for i in range(1, 100):
packet = yield from C.deliver_message()
print("%d %s : %s" % (i, packet.variable_header.topic_name, str(packet.payload.data)))
yield from C.acknowledge_delivery(packet.variable_header.packet_id)
yield from C.unsubscribe(['$SYS/broker/uptime'])
logger.info("UnSubscribed")
yield from C.disconnect()