From fdb6173405de91539eafd4dfca17a15ce1256b61 Mon Sep 17 00:00:00 2001 From: Nicolas Jouanin Date: Sun, 5 Jul 2015 15:53:02 +0200 Subject: [PATCH] Sample with keep alive ping --- samples/client_keepalive.py | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) create mode 100644 samples/client_keepalive.py diff --git a/samples/client_keepalive.py b/samples/client_keepalive.py new file mode 100644 index 0000000..d175202 --- /dev/null +++ b/samples/client_keepalive.py @@ -0,0 +1,24 @@ +import logging +from hbmqtt.client._client import MQTTClient +import asyncio + +logger = logging.getLogger(__name__) + +config = { + 'keep_alive': 5, + 'ping_delay': 1, +} +C = MQTTClient(config=config) + +@asyncio.coroutine +def test_coro(): + yield from C.connect(uri='mqtt://iot.eclipse.org:1883/', username=None, password=None) + yield from asyncio.sleep(18) + + yield from C.disconnect() + + +if __name__ == '__main__': + formatter = "[%(asctime)s] {%(filename)s:%(lineno)d} %(levelname)s - %(message)s" + logging.basicConfig(level=logging.DEBUG, format=formatter) + asyncio.get_event_loop().run_until_complete(test_coro()) \ No newline at end of file