Skip to main content

Python bindings to librabbitmq-c

Project description

Version:
0.5.0
Download:

http://pypi.python.org/pypi/pylibrabbitmq/

Code:

http://github.com/ask/pylibrabbitmq/

Keywords:

rabbitmq, amqp, messaging, librabbitmq, rabbitmq-c, python

Experimental Python bindings to the RabbitMQ C-library librabbitmq.

You should probably use amqplib instead, but when needed you can come back to this if the extra performance is needed.

Installation

To install you need to compile librabbitmq:

$ mkdir -p /opt/Build/rabbit
$ cd /opt/Build/rabbit
$ hg clone http://hg.rabbitmq.com/rabbitmq-codegen/
$ hg clone http://hg.rabbitmq.com/rabbitmq-c/
$ cd rabbitmq-c
$ autoreconf -i
$ ./configure
$ make
$ make install

Then you can install this package:

$ cd pylibrabbitmq-x.x.x
$ python setup.py install

Examples

>>> from pylibrabbitmq 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)

Produce

>>> m = Message(body, content_type=None, content_encoding=None,
...             delivery_mode=1)
>>> channel.basic_publish(m, exchange, routing_key, ...)

Consume

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

pylibrabbitmq-0.5.0.tar.gz (30.6 kB view details)

Uploaded Source

File details

Details for the file pylibrabbitmq-0.5.0.tar.gz.

File metadata

File hashes

Hashes for pylibrabbitmq-0.5.0.tar.gz
Algorithm Hash digest
SHA256 a22d57fcd4e8dfa289b5a8921c6d869170347b07b4116e420e1dac20fa6e7662
MD5 4e666893fed0f8d1d6e07a22707dca01
BLAKE2b-256 778e297cb11400939280c407a8701bac9bba96c8e80964b0285551dd80a91ef7

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