Skip to content
amqplib fork
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Type Name Latest commit message Commit time
Failed to load latest commit information.
amqp Ignore all methods except Close and Close-OK when channel/connection … Jun 13, 2019
docs Update version. Mar 26, 2019
extra Run Windows build with tox. Apr 3, 2019
requirements Pin sphinx_celery to 1.4.6. Jun 13, 2019
t Close channel in integration tests Jun 14, 2019
.bumpversion.cfg Bump version: 2.4.1 → 2.4.2 Mar 3, 2019
.cookiecutterrc Adds .cookiecutterrc Jul 6, 2016
.coveragerc Improve Linux version parsing to handle + and other characters. Closes Dec 14, 2016
.editorconfig [dist] Adds .editorconfig Apr 9, 2016
.gitignore Ignore pytest_cache. May 28, 2018
.hgtags Added tag 1.0.2 for changeset 124bd71678e2 Sep 29, 2011
.travis.yml Pin tox-docker to 1.2.1 for now. Jun 10, 2019
AUTHORS Adds Jon Dufresne to AUTHORS Dec 7, 2016
Changelog version 2.5.0 May 30, 2019
LICENSE LGPL -> BSD License to match Celery (#104) Aug 15, 2016 Use py.test Aug 24, 2016
Makefile Adds pydocstyle tox target Oct 11, 2016
README.rst Bump version: 2.4.1 → 2.4.2 Mar 3, 2019
appveyor.yml Drop 3.4 from Windows build. Jun 10, 2019 Added RabbitMQ integration tests (#257) Feb 18, 2019 Display rabbitmq logs on failure. Mar 19, 2019
setup.cfg Added integration tests (#213) Nov 6, 2018 Adds Python 3.7 to the list of supported languages in and ad… Mar 2, 2019
tox.ini Mark tox-docker as required. Jun 10, 2019 Use tox-docker in integration tests (#262) Mar 9, 2019


Python AMQP 0.9.1 client library

Build status coverage BSD License Python AMQP can be installed via wheel Supported Python versions. Support Python implementations.

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.

Differences from amqplib

  • 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.
  • Supports RabbitMQ extensions:
    • Consumer Cancel Notifications
      • by default a cancel results in ChannelError being raised
      • but not if a on_cancel callback is passed to basic_consume.
    • Publisher confirms
      • Channel.confirm_select() enables publisher confirms.
      •['basic_ack'].append(my_callback) adds a callback to be called when a message is confirmed. This callback is then called with the signature (delivery_tag, multiple).
    • Exchange-to-exchange bindings: exchange_bind / exchange_unbind.
      • Channel.confirm_select() enables publisher confirms.
      •['basic_ack'].append(my_callback) adds a callback to be called when a message is confirmed. This callback is then called with the signature (delivery_tag, multiple).
    • Authentication Failure Notifications
      Instead of just closing the connection abruptly on invalid credentials, py-amqp will raise an AccessRefused error when connected to rabbitmq-server 3.2.0 or greater.
  • Support for basic_return

  • Uses AMQP 0-9-1 instead of 0-8.
    • Channel.access_request and ticket arguments to methods removed.
    • Supports the arguments argument to basic_consume.
    • internal argument to exchange_declare removed.
    • auto_delete argument to exchange_declare deprecated
    • insist argument to Connection removed.
    • Channel.alerts has been removed.
    • Support for Channel.basic_recover_async.
    • Channel.basic_recover deprecated.
  • Exceptions renamed to have idiomatic names:
    • AMQPException -> AMQPError
    • AMQPConnectionException -> ConnectionError``
    • AMQPChannelException -> ChannelError``
    • Connection.known_hosts removed.
    • Connection no longer supports redirects.
    • exchange argument to queue_bind can now be empty to use the "default exchange".
  • 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


You can’t perform that action at this time.