librabbitmq

Version:: 1.6.0
Download:: http://pypi.python.org/pypi/librabbitmq/
Code:: http://github.com/celery/librabbitmq/
Keywords:: rabbitmq, amqp, messaging, librabbitmq, rabbitmq-c, python, kombu, celery

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

Installation

Install via pip:

$ pip install librabbitmq

or, install via easy_install:

$ easy_install librabbitmq

Downloading and installing from source

Download the latest version from: http://pypi.python.org/pypi/librabbitmq/

Then install it by doing the following,:

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

Using the development version

You can clone the repository by doing the following:

$ git clone git://github.com/celery/librabbitmq.git

Then install it by doing the following:

$ cd librabbitmq
$ make install        # or make develop

Examples

Using with Kombu:

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

Stand-alone:

>>> from librabbitmq import Connection

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

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

Producing

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

Consuming

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

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

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

Poll

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

Other

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

License

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.

Download files

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

Source Distribution

librabbitmq-1.6.1.tar.gz (529.1 kB view details)

Uploaded Nov 17, 2014 Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

The dropdown lists show the available interpreters, ABIs, and platforms. Enable javascript to be able to filter the list of wheel files.

librabbitmq-1.6.1-cp27-none-macosx_10_6_intel.whl (98.2 kB view details)

Uploaded Nov 17, 2014 CPython 2.7macOS 10.6+ Intel (x86-64, i386)

File details

Details for the file librabbitmq-1.6.1.tar.gz.

File metadata

Download URL: librabbitmq-1.6.1.tar.gz
Upload date: Nov 17, 2014
Size: 529.1 kB
Tags: Source
Uploaded using Trusted Publishing? No

File hashes

Hashes for librabbitmq-1.6.1.tar.gz
Algorithm	Hash digest
SHA256	`604a226b9fe3f9e439353702a731f2a39cf771882e68bca020cb224d9b990c49`
MD5	`716f05388d4747ea605c1a31f8541e3b`
BLAKE2b-256	`826c1b3f7ca755787e934513039131091134038239f167e1bc50565cb46112a0`

See more details on using hashes here.

File details

Details for the file librabbitmq-1.6.1-cp27-none-macosx_10_6_intel.whl.

File metadata

Download URL: librabbitmq-1.6.1-cp27-none-macosx_10_6_intel.whl
Upload date: Nov 17, 2014
Size: 98.2 kB
Tags: CPython 2.7, macOS 10.6+ Intel (x86-64, i386)
Uploaded using Trusted Publishing? No

File hashes

Hashes for librabbitmq-1.6.1-cp27-none-macosx_10_6_intel.whl
Algorithm	Hash digest
SHA256	`2c2d09014c13285e6303b3b7045a2e979b0ee7bca249946f1b94d80e2a1a2089`
MD5	`1bd79d76bb55d2f3ccb6fbfa03d2c957`
BLAKE2b-256	`ecd0a6f04b728ebd2a585a173752415aa0d320fae9b4b19f777b8946eaac0f42`