librabbitmq

AMQP Client using the rabbitmq-c library.

These details have been verified by PyPI

Maintainers

ask auvipy mher smorin the_drow

These details have not been verified by PyPI

Project links

Homepage

Development Status
- 3 - Alpha
Intended Audience
- Developers
License
- OSI Approved :: Mozilla Public License 1.0 (MPL)
Operating System
- OS Independent
Programming Language
- C
Topic

Project description

Version:: 0.9.3
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, Message

>>> 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

>>> m = Message(body, content_type=None, content_encoding=None,
...             delivery_mode=1)
>>> channel.basic_publish(m, 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.

Project details

These details have been verified by PyPI

Maintainers

ask auvipy mher smorin the_drow

These details have not been verified by PyPI

Project links

Homepage

Development Status
- 3 - Alpha
Intended Audience
- Developers
License
- OSI Approved :: Mozilla Public License 1.0 (MPL)
Operating System
- OS Independent
Programming Language
- C
Topic

Release history Release notifications | RSS feed

2.0.0

May 30, 2018

1.6.1

Nov 17, 2014

1.6.0

Nov 17, 2014

1.5.2

May 28, 2014

1.5.1

May 6, 2014

1.5.0

Apr 14, 2014

1.0.3

Nov 15, 2013

1.0.2

Oct 25, 2013

1.0.1

Jan 14, 2013

1.0.0

Nov 2, 2012

0.9.9

Jun 23, 2012

0.9.8

Jun 23, 2012

0.9.7

Jun 23, 2012

0.9.6

Jun 13, 2012

This version

0.9.5

Jun 7, 2012

0.9.4

May 29, 2012

0.9.3

May 22, 2012

0.9.2

May 21, 2012

0.9.1

May 21, 2012

0.9.0

May 21, 2012

Download files

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

Source Distribution

librabbitmq-0.9.5.tar.gz (442.6 kB view hashes)

Uploaded Jun 7, 2012 Source

Built Distributions

librabbitmq-0.9.5-py2.7-macosx-10.6-universal.egg (74.0 kB view hashes)

Uploaded Jun 7, 2012 Source

librabbitmq-0.9.5-py2.7-linux-i686.egg (153.8 kB view hashes)

Uploaded Jun 7, 2012 Source

librabbitmq-0.9.5-py2.6-macosx-10.7-universal.egg (67.6 kB view hashes)

Uploaded Jun 7, 2012 Source

librabbitmq-0.9.5-py2.6-linux-i686.egg (153.7 kB view hashes)

Uploaded Jun 7, 2012 Source

Hashes for librabbitmq-0.9.5.tar.gz

Hashes for librabbitmq-0.9.5.tar.gz
Algorithm	Hash digest
SHA256	`baff27cf7b0bacab2c51b81157bc1f28a4e826dc7af625c3e839bcec42604588`
MD5	`fb37d64149d4844153ef76e7584026fe`
BLAKE2b-256	`645906474f53a83792dc3ccc27bb16305646229235dfc1e165f5a7e8731fb4f6`

Hashes for librabbitmq-0.9.5-py2.7-macosx-10.6-universal.egg

Hashes for librabbitmq-0.9.5-py2.7-macosx-10.6-universal.egg
Algorithm	Hash digest
SHA256	`7071058ed5f7a03f0a133627d462e186c79d8f381673adbb1e10468fe4e879e5`
MD5	`a53df70f9eecced5841225c251b05eae`
BLAKE2b-256	`ca916ce983771b43bc0aae0d2ff230e8db9e902e6a65e7c390478d1c0fa912ef`

Hashes for librabbitmq-0.9.5-py2.7-linux-i686.egg

Hashes for librabbitmq-0.9.5-py2.7-linux-i686.egg
Algorithm	Hash digest
SHA256	`a75d77d3a6e6e3791ea775c1f1d263884f1a75e1a126600f8f8e441744f951d9`
MD5	`0623c16b27d7a739618cb8713709d289`
BLAKE2b-256	`34f744aedf4a17c93e39562344edc26160a90665328a8b037676f12f96a08478`

Hashes for librabbitmq-0.9.5-py2.6-macosx-10.7-universal.egg

Hashes for librabbitmq-0.9.5-py2.6-macosx-10.7-universal.egg
Algorithm	Hash digest
SHA256	`a553dc73542f6df38ceb98f78595eb4d7e15e59589dc40160604f1623ff312d8`
MD5	`d6875bf86e27b48afc03f9a4ab50f7ce`
BLAKE2b-256	`734cc4df7f46ed23eb1af3c63e77a58c12ff58491b241aa8231bfc3b47058133`

Hashes for librabbitmq-0.9.5-py2.6-linux-i686.egg

Hashes for librabbitmq-0.9.5-py2.6-linux-i686.egg
Algorithm	Hash digest
SHA256	`ed96dc876f465f2a335e84682330bcc82330a42751dbd5bee708c17d4588e83c`
MD5	`4ee1087d6dbf98408182430b1dc2d35a`
BLAKE2b-256	`9cd7cf961105a5422e5795155ab2fafa7f77178e018a302b39503807061dc13c`