/ unidist / messagequeue.py 

messagequeue

Message Queue management

TODO(g): Add auto-deleting options by count or age. Date tag their arrival in a dict so we can track stuff about it, and can maybe skip it.

TODO(g): Implement serialization, archiving, snapshotting, and replication to sharestate. This will allow us flexibility in many things. This is not necessarily going to be the best scaling solution, but it will work and provide a way to keep state and distribute. Name spaces should have this specified individually. If not specified, state will not be archived, serialized, snapshotted or replicated.

• Use the "archive" and "snapshot" modules for this, so archival and snapshotting is universal. Ensure a process restart will do the right thing in attempting to restore from snapshot, then archive, if present.

  TODO(g): Merge achive and snapshot. They are the same technology. If we really want to keep state, then we must archive each transactions and snapshot to avoid having to replay too many archives.

GetMessageCount ( queue )

AddMessage ( queue,  message )

GetMessage_Oldest ( queue,  remove=True )

GetAllMessages ( queue )

QueueExists ( queue )

GetMessage_Newest ( queue,  remove=True )