redis-simple-mq

🚨 This repository has moved!

We have migrated to GitHub. Please update your bookmarks and remotes to our new home: redis-simple-mq

This repository is now archived and will no longer be updated.

A simple message queue for Redis.

release python pipeline codecov Documentation Status license pre-commit Code style: black chat

Description

This is a light-weight message queue based on Redis.

Key features:

  • Class based API to the queue with all basic queue functions

  • Queue is implement as FIFO

  • All messages are stored and retrieved as UTF-8 strings

  • Bulk methods for enqueue and dequeue

  • No limit on the number of parallel queues

  • Fully tested

Basic example

from redis import Redis
from simple_mq import SimpleMQ

conn = Redis()
q = SimpleMQ(conn)
q.enqueue('Hello, World!')
message = q.dequeue()
print(message)

See also the examples folder for examples.