pip install simpleq from simpleq.queue import Queue import pika queue = Queue('my_queue') connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() def producer(message): queue.push(message) def consumer(): message = queue.pull()