How do I use NATS to replicate AWS SQS

[SarthakNarayan]

So I want a simple queueing service from NATS where my publisher can keep on putting messages in the queue and they persist unless they are acknowledged. I tried following the example on the following link and made 2 different files. One for subscriber and other for publisher but it doesn't work as expected. I only see one message instead of three.

publisher.py

import os
import asyncio

import nats
from nats.errors import TimeoutError

servers = os.environ.get("NATS_URL", "nats://localhost:4222").split(",")


async def main():
    # Create the connection to NATS which takes a list of servers.
    nc = await nats.connect(servers=servers)

    await nc.publish("greet.joe", b"hello")
    await nc.publish("greet.pam", b"hello")
    await nc.publish("greet.bob", b"hello")

    # await sub.unsubscribe()
    # await nc.drain()


if __name__ == "__main__":
    asyncio.run(main())

subscriber.py

import os
import asyncio

import nats
from nats.errors import TimeoutError

servers = os.environ.get("NATS_URL", "nats://localhost:4222").split(",")


async def main():
    # Create the connection to NATS which takes a list of servers.
    nc = await nats.connect(servers=servers)

    # create a subscription
    sub = await nc.subscribe("greet.*")

    try:
        msg = await sub.next_msg(timeout=0.1)
        print(msg)
    except TimeoutError:
        pass
        # print("timed out")


if __name__ == "__main__":
    while True:
        asyncio.run(main())

Am I doing something wrong? Thanks.