nats.py documentation (original) (raw)

import asyncio import nats

async def main(): # Connect to NATS! nc = await nats.connect("demo.nats.io")

# Receive messages on 'foo'
sub = await nc.subscribe("foo")

# Publish a message to 'foo'
await nc.publish("foo", b'Hello from Python!')

# Process a message
msg = await sub.next_msg()
print("Received:", msg)

# Make sure all published messages have reached the server
await nc.flush()

# Close NATS connection
await nc.close()

if name == 'main': asyncio.run(main())