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

updating sample to demonstrate failure

pull/236/head
Andrew Mirsky 2025-06-26 13:33:13 -04:00
rodzic 82c59cff9a
commit ecad0ce15b
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: A98E67635CDF2C39
1 zmienionych plików z 2 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

4
samples/client_publish.py
Wyświetl plik

@ -35,7 +35,7 @@ async def test_coro1() -> None:
async def test_coro2() -> None:
try:
client = MQTTClient(config={'auto_connect': False})
client = MQTTClient(config={'auto_reconnect': False, 'connection_timeout': 1})
await client.connect("mqtt://localhost:1884/")
await client.publish("a/b", b"TEST MESSAGE WITH QOS_0", qos=0x00)
await client.publish("a/b", b"TEST MESSAGE WITH QOS_1", qos=0x01)
@ -43,7 +43,7 @@ async def test_coro2() -> None:
logger.info("test_coro2 messages published")
await client.disconnect()
except ConnectError:
logger.exception(f"Connection failed", exc_info=True)
logger.info(f"Connection failed", exc_info=True)
def __main__():