search

adjust / rmq

Message queue system written in Go and backed by Redis
MIT License
1.56k stars 205 forks source link

delay queue function #129

Closed 0xbillw closed 1 year ago

0xbillw commented 1 year ago

Is there a delay queue function? Or are there plans to support that feature? Thank you!

wellle commented 1 year ago

Hey. I don't think we have exactly that. The way we approach this in our internal use is have our consumers sleep until a delivery is of certain age before it gets actually processed. For that your delivery needs to include something like a creation timestamp so you can check how old it is when the Consume() function gets called.

Additionally, for retries with delays we have push queues, see https://github.com/adjust/rmq#push-queues.

Hope that helps :v: