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

client reconnecting too quickly causing connection failure

pull/248/head
Andrew Mirsky 2025-07-02 14:01:53 -04:00
rodzic fa1894b837
commit 51d8c838f7
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
tests/test_broker.py
Wyświetl plik

@ -691,12 +691,12 @@ async def test_client_publish_clean_session_subscribe(broker):
await _client_publish("/qos0", b"data0", QOS_0) # should not be retained await _client_publish("/qos0", b"data0", QOS_0) # should not be retained
await _client_publish("/qos1", b"data1", QOS_1) await _client_publish("/qos1", b"data1", QOS_1)
await _client_publish("/qos2", b"data2", QOS_2) await _client_publish("/qos2", b"data2", QOS_2)
await asyncio.sleep(0.5) await asyncio.sleep(2)
await sub_client.reconnect(cleansession=False) await sub_client.reconnect(cleansession=False)
for qos in [QOS_1, QOS_2]: for qos in [QOS_1, QOS_2]:
log.debug(f"TEST QOS: {qos}") log.debug(f"TEST QOS: {qos}")
message = await sub_client.deliver_message() message = await sub_client.deliver_message(timeout_duration=2)
log.debug(f"Message: {message.publish_packet if message else None!r}") log.debug(f"Message: {message.publish_packet if message else None!r}")
assert message is not None assert message is not None
assert message.topic == f"/qos{qos}" assert message.topic == f"/qos{qos}"