123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152 |
- Metadata-Version: 2.0
- Name: librabbitmq
- Version: 1.6.1
- Summary: AMQP Client using the rabbitmq-c library.
- Home-page: http://github.com/celery/librabbitmq
- Author: Ask Solem
- Author-email: ask@celeryproject.org
- License: MPL
- Platform: UNKNOWN
- Classifier: Development Status :: 5 - Production/Stable
- Classifier: Operating System :: POSIX
- Classifier: Operating System :: Microsoft :: Windows
- Classifier: Programming Language :: C
- Classifier: Programming Language :: Python :: 2.5
- Classifier: Programming Language :: Python :: 2.6
- Classifier: Programming Language :: Python :: 2.7
- Classifier: Programming Language :: Python :: Implementation :: CPython
- Classifier: Intended Audience :: Developers
- Classifier: License :: OSI Approved :: Mozilla Public License 1.0 (MPL)
- Classifier: Topic :: Communications
- Classifier: Topic :: System :: Networking
- Classifier: Topic :: Software Development :: Libraries
- Requires-Dist: amqp (>=1.4.6)
- ================================================================
- librabbitmq - Python AMQP Client using the rabbitmq-c library.
- ================================================================
- :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
- .. contents::
- :local:
- Python bindings to the RabbitMQ C-library `rabbitmq-c`_.
- Supported by Kombu and Celery.
- .. _`rabbitmq-c`: https://github.com/alanxz/rabbitmq-c
- 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.
- .. # vim: syntax=rst expandtab tabstop=4 shiftwidth=4 shiftround
|