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

Cleanup

pull/8/head
Nico 2015-11-06 17:53:36 +01:00
rodzic f3d136a773
commit 8c8be854a8
1 zmienionych plików z 2 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

3
scripts/pub_script.py
Wyświetl plik

@ -106,9 +106,10 @@ def do_pub(client, arguments):
cadata=arguments['--ca-data']) cadata=arguments['--ca-data'])
qos = _get_qos(arguments) qos = _get_qos(arguments)
topic = arguments['-t'] topic = arguments['-t']
retain = arguments['-r']
for message in _get_message(arguments): for message in _get_message(arguments):
logger.info("%s Publishing to '%s'" % (client.client_id, topic)) logger.info("%s Publishing to '%s'" % (client.client_id, topic))
task = ensure_future(client.publish(topic, message, qos, arguments['-r'])) task = ensure_future(client.publish(topic, message, qos, retain))
running_tasks.append(task) running_tasks.append(task)
if running_tasks: if running_tasks:
yield from asyncio.wait(running_tasks) yield from asyncio.wait(running_tasks)