Skip to content
This repository has been archived by the owner on Jan 20, 2021. It is now read-only.
mgale edited this page Oct 5, 2011 · 2 revisions

Welcome to the MemQueue wiki!

A simple message queue for transient data that is time sensitive.

The message is stored in Memcached for speed, a non-locking implementation is used so many front end servers can add to the Queue as needed with out having to acquire and release locks.

The view of the Queue is based on time points, a start time of X compared to NOW. Since the data is in memcached and not persisted to disk there is no real guarantee that messages are still in the Queue at a later date. So instead of trying to provide an absolute view of the Queue we provide a window in to the Queue at time. By default when listing the messages in the Queue we show all messages that exist and that have arrived in the last 10 minutes.

You can ask for larger windows and based on your memcached usage and Queue usage the messages could be available. For example some memcached implementations do not auto purge old data and some write to disk async.

Clone this wiki locally