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

Add critical message if pub/sub operation is cancelled

pull/8/head
Nico 2015-11-04 22:12:03 +01:00
rodzic ddab6ff576
commit 09827d8a0f
2 zmienionych plików z 4 dodań i 0 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
scripts/pub_script.py
Wyświetl plik

@ -111,6 +111,8 @@ def do_pub(client, arguments):
logger.info("%s Disconnected from broker" % client.client_id) logger.info("%s Disconnected from broker" % client.client_id)
except ConnectException as ce: except ConnectException as ce:
logger.fatal("connection to '%s' failed: %r" % (arguments['--url'], ce)) logger.fatal("connection to '%s' failed: %r" % (arguments['--url'], ce))
except asyncio.CancelledError as cae:
logger.fatal("Publish canceled due to prvious error")
def main(*args, **kwargs): def main(*args, **kwargs):

2
scripts/sub_script.py
Wyświetl plik

@ -85,6 +85,8 @@ def do_sub(client, arguments):
yield from client.disconnect() yield from client.disconnect()
except ConnectException as ce: except ConnectException as ce:
logger.fatal("connection to '%s' failed: %r" % (arguments['--url'], ce)) logger.fatal("connection to '%s' failed: %r" % (arguments['--url'], ce))
except asyncio.CancelledError as cae:
logger.fatal("Publish canceled due to prvious error")
def main(*args, **kwargs): def main(*args, **kwargs):