Low-level AMQP client for Python (fork of amqplib).
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
For more information about AMQP, visit
For other Python client libraries see:
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
|File Name & Checksum SHA256 Checksum Help||Version||File Type||Upload Date|
|amqp-2.1.4-py2.py3-none-any.whl (49.2 kB) Copy SHA256 Checksum SHA256||2.7||Wheel||Dec 14, 2016|
|amqp-2.1.4.tar.gz (99.7 kB) Copy SHA256 Checksum SHA256||–||Source||Dec 14, 2016|