Skip to main content

Simple RabbitMQ consuming framework

Project description


RabbitLeap is a simple RabbitMQ consuming framework. It’s built on top of Pika, a RabbitMQ client library for Python.


  • Automatically recovers from connection failures
  • Configurable retry policy for handing failures
  • Automatically route messages to handlers, based on custom logic and different message properties


$ pip install rabbitleap

Hello, world

from rabbitleap.consumer import Consumer
from rabbitleap.handling import MessageHandler

class RabbitEatHandler(MessageHandler):

    def handle(self):
        print('rabbit eat: {}'.format(self.envelope.payload.decode('utf-8')))

consumer_queue_name = 'consumer_queue'
amqp_url = r'amqp://guest:guest@localhost:5672/%2f'

consumer = Consumer(amqp_url=amqp_url, queue_name=consumer_queue_name)
# route message of type `` to RabbitEatHandler
consumer.add_handler(r'rabbit\.eat', RabbitEatHandler)

except KeyboardInterrupt:


Documentation and resources are available at

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

rabbitleap-0.1.1.tar.gz (28.3 kB view hashes)

Uploaded source

Built Distribution

rabbitleap-0.1.1-py2.py3-none-any.whl (19.3 kB view hashes)

Uploaded py2 py3

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Huawei Huawei PSF Sponsor Microsoft Microsoft PSF Sponsor NVIDIA NVIDIA PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page