Skip to content
Python bindings to librabbitmq-c
C Python Makefile Shell
Latest commit 5b2e9e1 Mar 22, 2016 @ask ask Merge pull request #45 from rogerhu/pyerr_occurred
Check if the return value is -1.  If so, goto fail, which will invoke PyErr_Ocurred().


librabbitmq - Python AMQP Client using the rabbitmq-c library.

Version: 1.6.0
Keywords:rabbitmq, amqp, messaging, librabbitmq, rabbitmq-c, python, kombu, celery

Python bindings to the RabbitMQ C-library rabbitmq-c. Supported by Kombu and Celery.


Install via pip:

$ pip install librabbitmq

or, install via easy_install:

$ easy_install librabbitmq

Downloading and installing from source

Download the latest version from

Then install it by doing the following,:

$ tar xvfz librabbitmq-0.0.0.tar.gz
$ cd librabbitmq-0.0.0
$ python build
# python install # as root

Using the development version

You can clone the repository by doing the following:

$ git clone git://

Then install it by doing the following:

$ cd librabbitmq
$ make install        # or make develop


Using with Kombu:

>>> from kombu import Connection
>>> x = Connection("librabbitmq://")


>>> from librabbitmq import Connection

>>> conn = Connection(host="localhost", userid="guest",
...                   password="guest", virtual_host="/")

>>> channel =
>>> channel.exchange_declare(exchange, type, ...)
>>> channel.queue_declare(queue, ...)
>>> channel.queue_bind(queue, exchange, routing_key)


>>> channel.basic_publish(body, exchange, routing_key, ...)


>>> def dump_message(message):
...     print("Body:'%s', Properties:'%s', DeliveryInfo:'%s'" % (
...         message.body,, message.delivery_info))
...     message.ack()

>>> channel.basic_consume(queue, ..., callback=dump_message)

>>> while True:
...    connection.drain_events()


>>> message = channel.basic_get(queue, ...)
>>> if message:
...     dump_message(message)
...     print("Body:'%s' Properties:'%s' DeliveryInfo:'%s'" % (
...         message.body,, message.delivery_info))


>>> channel.queue_unbind(queue, ...)
>>> channel.close()
>>> connection.close()


This software is licensed under the Mozilla Public License. See the LICENSE-MPL-RabbitMQ file in the top distribution directory for the full license text.

Something went wrong with that request. Please try again.