kopia lustrzana https://github.com/Yakifo/amqtt
remove dependency on external broker
rodzic
e009b4b0da
commit
fa1894b837
|
@ -19,7 +19,7 @@ async def main() -> None:
|
||||||
client = MQTTClient(config=config)
|
client = MQTTClient(config=config)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
await client.connect("mqtt://test.mosquitto.org:1883/")
|
await client.connect("mqtt://localhost:1883/")
|
||||||
logger.info("client connected")
|
logger.info("client connected")
|
||||||
await asyncio.sleep(15)
|
await asyncio.sleep(15)
|
||||||
except CancelledError:
|
except CancelledError:
|
||||||
|
|
Ładowanie…
Reference in New Issue