diff --git a/samples/client_publish.py b/samples/client_publish.py index fcc432b..86634b3 100644 --- a/samples/client_publish.py +++ b/samples/client_publish.py @@ -45,10 +45,12 @@ def test_coro(): @asyncio.coroutine def test_coro2(): try: - future = yield from C.connect('mqtt://test:test@localhost:1883/') + future = yield from C.connect('mqtt://test.mosquitto.org:1883/') future.add_done_callback(disconnected) #yield from asyncio.wait([asyncio.async(C.publish('a/b', b'TEST MESSAGE WITH QOS_1', qos=0x01))]) - yield from asyncio.wait([asyncio.async(C.publish('a/b', b'TEST MESSAGE WITH QOS_2', qos=0x02))]) + message = yield from C.publish('a/b', b'TEST MESSAGE WITH QOS_2', qos=0x02) + message = yield from C.publish('a/b', b'TEST MESSAGE WITH QOS_0', qos=0x00) + #print(message) logger.info("messages published") yield from C.disconnect() except ConnectException as ce: