From cbf86e960556e6bfc2adf7b367c25ebbaed2bf8f Mon Sep 17 00:00:00 2001 From: Nico Date: Sun, 27 Sep 2015 21:17:28 +0200 Subject: [PATCH] remove unused --- hbmqtt/mqtt/protocol/handler.py | 9 --------- samples/client_subscribe.py | 1 - 2 files changed, 10 deletions(-) diff --git a/hbmqtt/mqtt/protocol/handler.py b/hbmqtt/mqtt/protocol/handler.py index 1d64789..7d971b3 100644 --- a/hbmqtt/mqtt/protocol/handler.py +++ b/hbmqtt/mqtt/protocol/handler.py @@ -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) diff --git a/samples/client_subscribe.py b/samples/client_subscribe.py index 4b1a1b2..c281955 100644 --- a/samples/client_subscribe.py +++ b/samples/client_subscribe.py @@ -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()