I've written memqueue (https://github.com/halayli/memqueue/ https://github.com/halayli/memqueue/) for similar purposes. Memqueue is a revision-based queue serv

I've written memqueue (https://github.com/halayli/memqueue/ https://github.com/halayli/memqueue/) for similar purposes. Memqueue is a revision-based queue server with a REST API. Multiple consumers can poll the same queue at a different pace by using revisions. A revision is sort of a cursor that allows a consumer to specify where to poll from in the queue. If a connection drops it's not a problem, you continue from the revision you stopped at after you reestablish a connection. Each time a new message arrives to the queue, the revision is bumped by one and consumers are expected to poll from the new revision. It also allows you to specify message & queue expiries so you don't have to manage memory growth.