pull/8/head
Nico 2015-09-27 21:17:12 +02:00
rodzic 01628e25a6
commit 8bafbeb0f2
1 zmienionych plików z 0 dodań i 8 usunięć

Wyświetl plik

@ -196,14 +196,6 @@ class MQTTClient:
self.logger.warn("unsubscribe while not connected to broker, message may be lost") self.logger.warn("unsubscribe while not connected to broker, message may be lost")
yield from self._handler.mqtt_unsubscribe(topics, self.session.next_packet_id) yield from self._handler.mqtt_unsubscribe(topics, self.session.next_packet_id)
@asyncio.coroutine
def deliver_message(self):
return (yield from self._handler.mqtt_deliver_next_message())
@asyncio.coroutine
def acknowledge_delivery(self, packet_id):
yield from self._handler.mqtt_acknowledge_delivery(packet_id)
@asyncio.coroutine @asyncio.coroutine
def _connect_coro(self): def _connect_coro(self):
sc = None sc = None