How to implement task queue using Solace
Hi, I would like to use Solace for a task queue though Solace is overkill for my needs, but I hope it can meet my use case.
I have 2 publishers putting guaranteed messages on a queue, and a single consumer listening to the queue initially, but the numbers of consumers scales up when there are many messages on the queue. When a consumer receives a task, it runs a function which takes ~1 minute to run.
I would like each consumer to take a single message from the queue and only take the next message once the function which processes the message is done (about ~1 minute later). I would like the consumers to listen for messages asynchronously to avoid delays that come with polling. The reason I want each consumer to take a single task is because when a new consumer is spun up, I want it to be able to start processing the next message, rather than having that message wait on the pre-existing consumer until it finishes processing it's first message.
Is this possible? I'm using the python client if that's helpful. Thanks in advance.