vmihailenco/taskq

add message to queue that has a timeout to be processed

aon108 opened this issue · 1 comments

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

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.