mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Change current test conditions

pull/8/head
Nicolas Jouanin 2015-09-10 22:41:11 +02:00
rodzic 3c656ef95b
commit e77c9d7a49
1 zmienionych plików z 4 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
samples/client_publish.py
Wyświetl plik

@ -45,10 +45,12 @@ def test_coro():
@asyncio.coroutine @asyncio.coroutine
def test_coro2(): def test_coro2():
try: 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) 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_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") logger.info("messages published")
yield from C.disconnect() yield from C.disconnect()
except ConnectException as ce: except ConnectException as ce: