Version: | 1.2.0 |
---|---|
Web: | http://amqp.readthedocs.org/ |
Download: | http://pypi.python.org/pypi/amqp/ |
Source: | http://github.com/celery/py-amqp/ |
Keywords: | amqp, rabbitmq |
This is a fork of amqplib which was originally written by Barry Pederson. It is maintained by the Celery project, and used by kombu as a pure python alternative when librabbitmq is not available.
This library should be API compatible with librabbitmq.
Supports draining events from multiple channels (Connection.drain_events)
Support for timeouts
Channels are restored after channel error, instead of having to close the connection.
Support for heartbeats
- Connection.heartbeat_tick(rate=2) must called at regular intervals (half of the heartbeat value if rate is 2).
- Or some other scheme by using Connection.send_heartbeat.
Support for basic_return
Adds Connection.is_alive that tries to detect whether the connection can still be used.
Adds Connection.connection_errors and .channel_errors, a list of recoverable errors.
Exposes the underlying socket as Connection.sock.
Adds Channel.no_ack_consumers to keep track of consumer tags that set the no_ack flag.
Slightly better at error recovery
Differences between AMQP 0.8 and 0.9.1
AMQP 0.9.1 Quick Reference
RabbitMQ Extensions
For more information about AMQP, visit
For other Python client libraries see: