nats_py_async_connect_publish_subscribe_quickstart.py

1import asyncio
2import nats
3from nats.errors import ConnectionClosedError, TimeoutError, NoServersError
4
5async def main():
6    nc = await nats.connect("nats://demo.nats.io:4222")
7
8    # Create a simple subscription
9    sub = await nc.subscribe("updates")
10
11    # Publish a message
12    await nc.publish("updates", b"All is Well")
13
14    # Receive the message
15    msg = await sub.next_msg()
16    print(f"Received a message on '{msg.subject}': {msg.data.decode()}")
17
18    # Close the connection
19    await nc.close()
20
21if __name__ == '__main__':
22    asyncio.run(main())