You are here: Home / LBN / Up2date / Zenoss 4 / BastionLinux 13 / python-amqp-1.0.6-1.lbn13.noarch

python-amqp-1.0.6-1.lbn13.noarch

Package Attributes
RPM  python-amqp-1.0.6-1.lbn13.noarch.rpm Architecture  noarch Size  346565 Created  2017/08/04 11:09:42 UTC
Package Specification
Summary Client library for AMQP
Group Development/Languages
License LGPLv2+
Home Page http://pypi.python.org/pypi/amqplib
Description

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). o Or some other scheme by using Connection.send_heartbeat.

*

Supports RabbitMQ extensions: o

Consumer Cancel Notifications + by default a cancel results in ChannelError being raised + but not if a on_cancel callback is passed to basic_consume.

o

Publisher confirms + Channel.confirm_select() enables publisher confirms. + Channel.events['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).

o

Exchange-to-exchange bindings: exchange_bind / exchange_unbind. + Channel.confirm_select() enables publisher confirms. + Channel.events['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).

*

Support for basic_return *

Uses AMQP 0-9-1 instead of 0-8. o Channel.access_request and ticket arguments to methods removed. o Supports the arguments argument to basic_consume. o internal argument to exchange_declare removed. o auto_delete argument to exchange_declare deprecated o insist argument to Connection removed. o Channel.alerts has been removed. o Support for Channel.basic_recover_async. o Channel.basic_recover deprecated.

*

Exceptions renamed to have idiomatic names: o AMQPException -> AMQPError o AMQPConnectionException -> ConnectionError`` o AMQPChannelException -> ChannelError`` o Connection.known_hosts removed. o Connection no longer supports redirects. o 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

Requires
rpmlib(PayloadFilesHavePrefix)  
rpmlib(FileDigests)  
rpmlib(CompressedFileNames)  
rpmlib(PartialHardlinkSets)  
rpmlib(PayloadIsXz)  
Provides
python-amqp

Document Actions