Skip to main content

AMQP Client using the rabbitmq-c library.

Project description

Version:
1.5.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.

Project details


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.5.0.tar.gz (649.9 kB view details)

Uploaded Source

Built Distribution

librabbitmq-1.5.0-cp27-none-macosx_10_9_intel.whl (96.3 kB view details)

Uploaded CPython 2.7 macOS 10.9+ intel

File details

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

File metadata

  • Download URL: librabbitmq-1.5.0.tar.gz
  • Upload date:
  • Size: 649.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for librabbitmq-1.5.0.tar.gz
Algorithm Hash digest
SHA256 6adbfcdc7b8e7e8983961e87a096c7df1ddc2a8b28873d01b8859253dab86a9d
MD5 38ed8146302d659a9937127919e95ae9
BLAKE2b-256 3193ae3c6be89c6d89c7264d290135810b8ac8ef3571aabe1330c28cf9e20e92

See more details on using hashes here.

Provenance

File details

Details for the file librabbitmq-1.5.0-cp27-none-macosx_10_9_intel.whl.

File metadata

File hashes

Hashes for librabbitmq-1.5.0-cp27-none-macosx_10_9_intel.whl
Algorithm Hash digest
SHA256 d0b938c013d5c0e4678ff3bdd5c633c2e2ae3a6a67db23cc705bcfc1886705a2
MD5 0687bac0067a5fc2698988414bd49b5b
BLAKE2b-256 ad30b0facf57ac5257acca198e7f407926cc79f595da0ddc91feda4627bfa228

See more details on using hashes here.

Provenance

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page