add message to queue that has a timeout to be processed
aon108 opened this issue · 1 comments
aon108 commented
Hey, thanks for a great package.
Please could you help with what would be the best way to add a task to the queue with a timeout.
That if it does not get processed in X seconds (say 30) it is deleted from the queue.
I was looking through the message with context documentation but that only mentioned stopping all tasks that a consumer might be working on and not on an individual basis.
Thank you
aon108 commented
Having thought some more about this - i'm just going to add an expires field in the task payload and check it when the task is picked up by the consumer and complete it if it has expired.
Closed.