bunnymq 0.0.3

Simple transparent wrapper for a small portion of Pika. It has a nice interface.

BunnyMQ

Simple messaging with RabbitMQ and Python.

Basic Usage:

>>> queue = Queue('test')

>>> queue.put(1)
>>> queue.put('hello', priority=8)
>>> queue.put({'a': 1})

>>> queue.get()
'hello'
>>> queue.task_done()

>>> queue.get()
1
>>> queue.requeue()

Iterating over a queue indefinitely, waiting if nothing is available:

>>> for item in queue:
...     print(item)
...     queue.task_done()

Head over to the tutorial to get started.

Features

• Simple usage
• Automatic serialization and deserialization of Python objects
• Automatic retry while publishing
• Automatic handling of connection failures while consuming
• Automatic handling of message redeliveries because of failure to send acknowledgement at the end of processing. This is a frequent scenario for long running consumer tasks. If you have encountered this problem, do read the details.
• Easy parallelization by starting multiple workers to share the load.

Install

pip install bunnymq

Requirements

• Python 3.6+
• RabbitMQ server
• Pika