| CARVIEW |
Select Language
HTTP/2 302
server: nginx
date: Sat, 09 Aug 2025 04:16:04 GMT
content-type: text/plain; charset=utf-8
content-length: 0
x-archive-redirect-reason: found capture at 20100707085731
location: https://web.archive.org/web/20100707085731/https://github.com/ask/pylibrabbitmq
server-timing: captures_list;dur=0.621455, exclusion.robots;dur=0.023840, exclusion.robots.policy;dur=0.010684, esindex;dur=0.011513, cdx.remote;dur=20.616204, LoadShardBlock;dur=190.728644, PetaboxLoader3.datanode;dur=69.753166, PetaboxLoader3.resolve;dur=75.706387
x-app-server: wwwb-app217
x-ts: 302
x-tr: 247
server-timing: TR;dur=0,Tw;dur=0,Tc;dur=0
set-cookie: wb-p-SERVER=wwwb-app217; path=/
x-location: All
x-rl: 0
x-na: 0
x-page-cache: MISS
server-timing: MISS
x-nid: DigitalOcean
referrer-policy: no-referrer-when-downgrade
permissions-policy: interest-cohort=()
HTTP/2 200
server: nginx
date: Sat, 09 Aug 2025 04:16:05 GMT
content-type: text/html; charset=utf-8
x-archive-orig-server: nginx/0.7.61
x-archive-orig-date: Wed, 07 Jul 2010 08:57:31 GMT
x-archive-orig-connection: close
x-archive-orig-status: 200 OK
x-archive-orig-etag: "da7b4735c5299677651a5244416de8d1"
x-archive-orig-x-runtime: 106ms
x-archive-orig-content-length: 29717
x-archive-orig-cache-control: private, max-age=0, must-revalidate
x-archive-guessed-content-type: text/html
x-archive-guessed-charset: utf-8
memento-datetime: Wed, 07 Jul 2010 08:57:31 GMT
link: ; rel="original", ; rel="timemap"; type="application/link-format", ; rel="timegate", ; rel="first memento"; datetime="Wed, 07 Jul 2010 08:57:31 GMT", ; rel="memento"; datetime="Wed, 07 Jul 2010 08:57:31 GMT", ; rel="next memento"; datetime="Mon, 11 Jun 2018 00:14:02 GMT", ; rel="last memento"; datetime="Sun, 22 Nov 2020 13:28:54 GMT"
content-security-policy: default-src 'self' 'unsafe-eval' 'unsafe-inline' data: blob: archive.org web.archive.org web-static.archive.org wayback-api.archive.org athena.archive.org analytics.archive.org pragma.archivelab.org wwwb-events.archive.org
x-archive-src: 52_16_20100707080342_crawl102-c/52_16_20100707085653_crawl101.arc.gz
server-timing: captures_list;dur=0.447102, exclusion.robots;dur=0.021476, exclusion.robots.policy;dur=0.009660, esindex;dur=0.010811, cdx.remote;dur=12.952056, LoadShardBlock;dur=205.453385, PetaboxLoader3.datanode;dur=96.665785, PetaboxLoader3.resolve;dur=264.649313, load_resource;dur=265.328297
x-app-server: wwwb-app217
x-ts: 200
x-tr: 541
server-timing: TR;dur=0,Tw;dur=0,Tc;dur=0
x-location: All
x-rl: 0
x-na: 0
x-page-cache: MISS
server-timing: MISS
x-nid: DigitalOcean
referrer-policy: no-referrer-when-downgrade
permissions-policy: interest-cohort=()
content-encoding: gzip
ask's pylibrabbitmq at master - GitHub
ask / pylibrabbitmq
- Source
- Commits
- Network (1)
- Issues (0)
- Downloads (0)
- Wiki (1)
- Graphs
-
Branch:
master
click here to add a description
click here to add a homepage
README.rst
pylibrabbitmq - Python bindings to librabbitmq-c
| Version: | 0.0.2 |
|---|---|
| Download: | https://pypi.python.org/pypi/pylibrabbitmq/ |
| Code: | https://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 https://hg.rabbitmq.com/rabbitmq-codegen/ $ hg clone https://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.