nats_py_async_subscribe_publish_message_quickstart.py

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