forked from pool/python-kombu
865d1c7c99
- New pyamqp:// transport!
The new py-amqp library is a fork of amqplib started with the
following goals:
- Uses AMQP 0.9.1 instead of 0.8
- Should support all RabbitMQ extensions
- API compatible with librabbitmq so that it can be used
as a pure-python replacement in environments where rabbitmq-c cannot
be compiled.
py-amqp: http://amqp.readthedocs.org/
If you start using use py-amqp instead of amqplib you can enjoy many
advantages including:
- Heartbeat support (Issue #79 + Issue #131)
- Consumer Cancel Notifications (Issue #131)
- Publisher Confirms
amqplib has not been updated in a long while, so maintaining our own fork
ensures that we can quickly roll out new features and fixes without
resorting to monkey patching.
To use the py-amqp transport you must install the amqp library:
$ pip install amqp
and change the connection URL to use the correct transport:
>>> conn = Connection('pyamqp://guest:guest@localhost//')
The pyamqp:// transport will be the default fallback transport
in Kombu version 3.0, when librabbitmq is not installed,
and librabbitmq will also be updated to support the same features.
- Connection now supports heartbeat argument.
If enabled you must make sure to manually maintain heartbeats
by calling the Connection.heartbeat_check at twice the rate
of the specified heartbeat interval.
E.g. if you have Connection(heartbeat=10),
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-kombu?expand=0&rev=47
|
||
|---|---|---|
| .gitattributes | ||
| .gitignore | ||
| kombu-2.3.0.tar.gz | ||
| python-kombu.changes | ||
| python-kombu.spec | ||