[Python-modules-commits] [kombu] 01/01: New upstream version 4.0.2+dfsg
Christopher Stuart Hoskin
mans0954 at moszumanska.debian.org
Tue Mar 21 21:33:49 UTC 2017
This is an automated email from the git hooks/post-receive script.
mans0954 pushed a commit to branch upstream
in repository kombu.
commit d6ac62c7614f9abc3aa637aaac61992d05d1a533
Author: Christopher Hoskin <mans0954 at debian.org>
Date: Tue Mar 21 19:30:27 2017 +0000
New upstream version 4.0.2+dfsg
---
AUTHORS | 16 +-
Changelog | 581 +++-
LICENSE | 2 +-
MANIFEST.in | 6 +
PKG-INFO | 187 +-
README.rst | 173 +-
docs/.templates/sidebarintro.html | 7 -
docs/.templates/sidebarlogo.html | 3 -
docs/Makefile | 221 +-
docs/{.static => _ext}/.keep | 0
docs/_ext/applyxrefs.py | 88 -
docs/_ext/literals_to_xrefs.py | 180 --
docs/{.static => _static}/.keep | 0
docs/_templates/sidebardonations.html | 10 +
docs/_theme/celery/static/celery.css_t | 394 ---
docs/_theme/celery/theme.conf | 5 -
docs/changelog.rst | 3373 +-------------------
docs/conf.py | 133 +-
docs/faq.rst | 17 +-
docs/images/favicon.ico | Bin 0 -> 5393 bytes
docs/includes/installation.txt | 27 +
README.rst => docs/includes/introduction.txt | 153 +-
docs/includes/resources.txt | 30 +
docs/introduction.rst | 329 +-
docs/make.bat | 272 ++
docs/reference/index.rst | 43 +-
docs/reference/kombu.abstract.rst | 4 +
...bu.async.rst => kombu.async.aws.connection.rst} | 6 +-
.../{kombu.async.rst => kombu.async.aws.rst} | 6 +-
...sync.rst => kombu.async.aws.sqs.connection.rst} | 6 +-
...u.async.rst => kombu.async.aws.sqs.message.rst} | 6 +-
...mbu.async.rst => kombu.async.aws.sqs.queue.rst} | 6 +-
.../{kombu.async.rst => kombu.async.aws.sqs.rst} | 6 +-
docs/reference/kombu.async.debug.rst | 2 +-
.../{kombu.async.rst => kombu.async.http.base.rst} | 6 +-
.../{kombu.async.rst => kombu.async.http.curl.rst} | 6 +-
.../{kombu.async.rst => kombu.async.http.rst} | 6 +-
docs/reference/kombu.async.hub.rst | 2 +-
docs/reference/kombu.async.rst | 2 +-
docs/reference/kombu.async.semaphore.rst | 2 +-
docs/reference/kombu.async.timer.rst | 2 +-
docs/reference/kombu.clocks.rst | 2 +-
docs/reference/kombu.common.rst | 2 +-
docs/reference/kombu.compat.rst | 4 +
docs/reference/kombu.compression.rst | 4 +
docs/reference/kombu.connection.rst | 4 +-
docs/reference/kombu.exceptions.rst | 4 +
docs/reference/kombu.five.rst | 2 +-
docs/reference/kombu.log.rst | 2 +-
docs/reference/kombu.message.rst | 2 +-
docs/reference/kombu.mixins.rst | 2 +-
docs/reference/kombu.pidbox.rst | 19 +-
docs/reference/kombu.pools.rst | 2 +-
.../{kombu.async.rst => kombu.resource.rst} | 6 +-
docs/reference/kombu.rst | 16 +-
docs/reference/kombu.serialization.rst | 4 +
docs/reference/kombu.simple.rst | 8 +-
docs/reference/kombu.syn.rst | 11 -
docs/reference/kombu.transport.SLMQ.rst | 6 +-
docs/reference/kombu.transport.SQS.rst | 4 +
docs/reference/kombu.transport.amqplib.rst | 36 -
docs/reference/kombu.transport.base.rst | 4 +
docs/reference/kombu.transport.beanstalk.rst | 20 -
...port.couchdb.rst => kombu.transport.consul.rst} | 13 +-
...go.management.commands.clean_kombu_messages.rst | 14 -
docs/reference/kombu.transport.django.managers.rst | 11 -
docs/reference/kombu.transport.django.models.rst | 11 -
...ansport.django.rst => kombu.transport.etcd.rst} | 10 +-
docs/reference/kombu.transport.filesystem.rst | 4 +
docs/reference/kombu.transport.librabbitmq.rst | 4 +
docs/reference/kombu.transport.memory.rst | 4 +
docs/reference/kombu.transport.mongodb.rst | 4 +
docs/reference/kombu.transport.pyamqp.rst | 4 +
docs/reference/kombu.transport.pyro.rst | 4 +
docs/reference/kombu.transport.qpid.rst | 4 +
docs/reference/kombu.transport.redis.rst | 4 +
docs/reference/kombu.transport.rst | 4 +
.../kombu.transport.sqlalchemy.models.rst | 27 -
docs/reference/kombu.transport.sqlalchemy.rst | 25 -
.../reference/kombu.transport.virtual.exchange.rst | 4 +
docs/reference/kombu.transport.virtual.rst | 4 +
.../kombu.transport.virtual.scheduling.rst | 7 -
docs/reference/kombu.transport.zmq.rst | 13 -
docs/reference/kombu.transport.zookeeper.rst | 6 +-
docs/reference/kombu.utils.amq_manager.rst | 6 +-
...kombu.async.rst => kombu.utils.collections.rst} | 6 +-
docs/reference/kombu.utils.compat.rst | 2 +-
docs/reference/kombu.utils.debug.rst | 2 +-
.../{kombu.async.rst => kombu.utils.div.rst} | 6 +-
docs/reference/kombu.utils.encoding.rst | 2 +-
docs/reference/kombu.utils.eventio.rst | 2 +-
docs/reference/kombu.utils.functional.rst | 2 +-
.../{kombu.async.rst => kombu.utils.imports.rst} | 6 +-
.../{kombu.async.rst => kombu.utils.json.rst} | 6 +-
docs/reference/kombu.utils.limits.rst | 2 +-
.../{kombu.async.rst => kombu.utils.objects.rst} | 6 +-
docs/reference/kombu.utils.rst | 11 -
docs/reference/kombu.utils.scheduling.rst | 11 +
docs/reference/kombu.utils.text.rst | 2 +-
.../{kombu.async.rst => kombu.utils.time.rst} | 6 +-
docs/reference/kombu.utils.url.rst | 2 +-
.../{kombu.async.rst => kombu.utils.uuid.rst} | 6 +-
docs/templates/readme.txt | 35 +
docs/userguide/connections.rst | 88 +-
docs/userguide/consumers.rst | 78 +-
docs/userguide/examples.rst | 2 -
docs/userguide/introduction.rst | 18 +-
docs/userguide/pools.rst | 18 +-
docs/userguide/producers.rst | 102 +-
docs/userguide/serialization.rst | 35 +-
docs/userguide/simple.rst | 4 +-
examples/complete_receive.py | 12 +-
examples/complete_send.py | 4 +-
examples/experimental/async_consume.py | 5 +-
examples/hello_consumer.py | 5 +-
examples/hello_publisher.py | 10 +-
examples/memory_transport.py | 24 +
examples/rpc-tut6/rpc_client.py | 46 +
examples/rpc-tut6/rpc_server.py | 58 +
examples/simple_eventlet_receive.py | 2 +
examples/simple_eventlet_send.py | 4 +-
examples/simple_receive.py | 2 +
examples/simple_send.py | 2 +
examples/simple_task_queue/client.py | 12 +-
examples/simple_task_queue/queues.py | 2 +
examples/simple_task_queue/tasks.py | 7 +-
examples/simple_task_queue/worker.py | 6 +-
extra/doc2ghpages | 13 -
extra/release/bump_version.py | 169 -
extra/release/doc4allmods | 40 -
extra/release/flakeplus.py | 125 -
extra/release/removepyc.sh | 3 -
extra/release/verify-reference-index.sh | 19 -
extra/requirements/default.txt | 3 +-
extra/requirements/dev.txt | 1 +
extra/requirements/docs.txt | 5 +-
extra/requirements/extras/beanstalk.txt | 1 -
extra/requirements/extras/consul.txt | 1 +
extra/requirements/extras/couchdb.txt | 2 +-
extra/requirements/extras/etcd.txt | 1 +
extra/requirements/extras/kazoo.txt | 1 -
extra/requirements/extras/librabbitmq.txt | 2 +-
extra/requirements/extras/mongodb.txt | 2 +-
extra/requirements/extras/redis.txt | 2 +-
extra/requirements/extras/sqlalchemy.txt | 1 -
extra/requirements/extras/sqs.txt | 3 +-
extra/requirements/extras/zeromq.txt | 1 -
extra/requirements/funtest.txt | 13 -
extra/requirements/pkgutils.txt | 11 +-
extra/requirements/py26.txt | 2 -
extra/requirements/test-ci-py2.txt | 1 +
extra/requirements/test-ci.txt | 7 +-
extra/requirements/test-ci3.txt | 5 -
extra/requirements/test.txt | 6 +-
extra/requirements/test3.txt | 3 -
funtests/setup.cfg | 4 -
funtests/setup.py | 67 -
funtests/tests/test_SLMQ.py | 29 -
funtests/tests/test_SQS.py | 29 -
funtests/tests/test_amqplib.py | 14 -
funtests/tests/test_beanstalk.py | 19 -
funtests/tests/test_couchdb.py | 18 -
funtests/tests/test_django.py | 37 -
funtests/tests/test_librabbitmq.py | 14 -
funtests/tests/test_qpid.py | 14 -
funtests/tests/test_redis.py | 22 -
funtests/tests/test_sqla.py | 16 -
kombu/__init__.py | 61 +-
kombu/abstract.py | 37 +-
kombu/async/__init__.py | 10 +-
kombu/async/aws/__init__.py | 10 +
kombu/async/aws/connection.py | 295 ++
kombu/async/aws/ext.py | 29 +
kombu/async/aws/sqs/__init__.py | 22 +
kombu/async/aws/sqs/connection.py | 199 ++
kombu/async/aws/sqs/ext.py | 32 +
kombu/async/aws/sqs/message.py | 46 +
kombu/async/aws/sqs/queue.py | 131 +
kombu/async/debug.py | 15 +-
kombu/async/http/__init__.py | 23 +
kombu/async/http/base.py | 253 ++
kombu/async/http/curl.py | 280 ++
kombu/async/hub.py | 53 +-
kombu/async/semaphore.py | 44 +-
kombu/async/timer.py | 98 +-
kombu/clocks.py | 34 +-
kombu/common.py | 167 +-
kombu/compat.py | 15 +-
kombu/compression.py | 35 +-
kombu/connection.py | 750 ++---
kombu/entity.py | 709 ++--
kombu/exceptions.py | 66 +-
kombu/five.py | 206 +-
kombu/log.py | 17 +-
kombu/message.py | 147 +-
kombu/messaging.py | 355 +-
kombu/mixins.py | 107 +-
kombu/pidbox.py | 103 +-
kombu/pools.py | 58 +-
kombu/resource.py | 229 ++
kombu/serialization.py | 259 +-
kombu/simple.py | 18 +-
kombu/syn.py | 53 -
kombu/tests/async/test_hub.py | 33 -
kombu/tests/case.py | 219 --
kombu/tests/test_clocks.py | 104 -
kombu/tests/test_compression.py | 50 -
kombu/tests/test_syn.py | 61 -
kombu/tests/transport/test_amqplib.py | 162 -
kombu/tests/transport/test_mongodb.py | 120 -
kombu/tests/transport/test_sqlalchemy.py | 69 -
kombu/tests/transport/test_transport.py | 44 -
kombu/tests/transport/virtual/test_exchange.py | 161 -
kombu/tests/transport/virtual/test_scheduling.py | 67 -
kombu/tests/utils/test_encoding.py | 102 -
kombu/tests/utils/test_functional.py | 63 -
kombu/tests/utils/test_utils.py | 412 ---
kombu/transport/SLMQ.py | 30 +-
kombu/transport/SQS.py | 459 ++-
kombu/transport/__init__.py | 60 +-
kombu/transport/amqplib.py | 401 ---
kombu/transport/base.py | 134 +-
kombu/transport/beanstalk.py | 155 -
kombu/transport/consul.py | 292 ++
kombu/transport/couchdb.py | 142 -
kombu/transport/django/__init__.py | 83 -
.../management/commands/clean_kombu_messages.py | 22 -
kombu/transport/django/managers.py | 95 -
kombu/transport/django/migrations/0001_initial.py | 51 -
kombu/transport/django/migrations/__init__.py | 16 -
kombu/transport/django/models.py | 38 -
.../django/south_migrations/0001_initial.py | 57 -
kombu/transport/etcd.py | 272 ++
kombu/transport/filesystem.py | 24 +-
kombu/transport/librabbitmq.py | 29 +-
kombu/transport/memory.py | 19 +-
kombu/transport/mongodb.py | 377 ++-
kombu/transport/pyamqp.py | 52 +-
kombu/transport/pyro.py | 16 +-
kombu/transport/qpid.py | 82 +-
kombu/transport/redis.py | 472 +--
kombu/transport/sqlalchemy/__init__.py | 160 -
kombu/transport/sqlalchemy/models.py | 62 -
kombu/transport/virtual/__init__.py | 863 +----
kombu/transport/virtual/{__init__.py => base.py} | 383 ++-
kombu/transport/virtual/exchange.py | 83 +-
kombu/transport/virtual/scheduling.py | 49 -
kombu/transport/zmq.py | 314 --
kombu/transport/zookeeper.py | 58 +-
kombu/utils/__init__.py | 473 +--
kombu/utils/amq_manager.py | 4 +-
kombu/utils/collections.py | 43 +
kombu/utils/compat.py | 159 +-
kombu/utils/debug.py | 18 +-
kombu/utils/div.py | 34 +
kombu/utils/encoding.py | 28 +-
kombu/utils/eventio.py | 156 +-
kombu/utils/functional.py | 304 +-
kombu/utils/imports.py | 65 +
kombu/utils/json.py | 96 +
kombu/utils/limits.py | 58 +-
kombu/utils/objects.py | 65 +
kombu/utils/scheduling.py | 114 +
kombu/utils/text.py | 24 +-
kombu/utils/time.py | 10 +
kombu/utils/url.py | 91 +-
kombu/utils/uuid.py | 13 +
requirements/default.txt | 3 +-
requirements/dev.txt | 1 +
requirements/docs.txt | 5 +-
requirements/extras/beanstalk.txt | 1 -
requirements/extras/consul.txt | 1 +
requirements/extras/couchdb.txt | 2 +-
requirements/extras/etcd.txt | 1 +
requirements/extras/kazoo.txt | 1 -
requirements/extras/librabbitmq.txt | 2 +-
requirements/extras/mongodb.txt | 2 +-
requirements/extras/redis.txt | 2 +-
requirements/extras/sqlalchemy.txt | 1 -
requirements/extras/sqs.txt | 3 +-
requirements/extras/zeromq.txt | 1 -
requirements/funtest.txt | 13 -
requirements/pkgutils.txt | 11 +-
requirements/py26.txt | 2 -
requirements/test-ci-py2.txt | 1 +
requirements/test-ci.txt | 7 +-
requirements/test-ci3.txt | 5 -
requirements/test.txt | 6 +-
requirements/test3.txt | 3 -
setup.cfg | 28 +-
setup.py | 103 +-
{kombu/tests/async => t}/__init__.py | 0
{funtests => t/integration}/__init__.py | 2 +
{funtests => t/integration}/tests/__init__.py | 2 +
t/integration/tests/test_SLMQ.py | 20 +
t/integration/tests/test_SQS.py | 21 +
{funtests => t/integration}/tests/test_amqp.py | 2 +
t/integration/tests/test_librabbitmq.py | 11 +
{funtests => t/integration}/tests/test_mongodb.py | 14 +-
{funtests => t/integration}/tests/test_pyamqp.py | 2 +
t/integration/tests/test_qpid.py | 11 +
t/integration/tests/test_redis.py | 20 +
.../integration}/tests/test_zookeeper.py | 11 +-
{funtests => t/integration}/transport.py | 26 +-
{kombu/tests => t}/mocks.py | 30 +-
t/unit/__init__.py | 1 +
.../tests/transport => t/unit/async}/__init__.py | 0
.../virtual => t/unit/async/aws}/__init__.py | 0
t/unit/async/aws/case.py | 14 +
.../utils => t/unit/async/aws/sqs}/__init__.py | 0
t/unit/async/aws/sqs/test_connection.py | 323 ++
t/unit/async/aws/sqs/test_message.py | 37 +
t/unit/async/aws/sqs/test_queue.py | 207 ++
t/unit/async/aws/sqs/test_sqs.py | 34 +
t/unit/async/aws/test_aws.py | 16 +
t/unit/async/aws/test_connection.py | 436 +++
.../management => t/unit/async/http}/__init__.py | 0
t/unit/async/http/test_curl.py | 134 +
t/unit/async/http/test_http.py | 157 +
t/unit/async/test_hub.py | 528 +++
{kombu/tests => t/unit}/async/test_semaphore.py | 26 +-
t/unit/async/test_timer.py | 158 +
kombu/tests/__init__.py => t/unit/conftest.py | 74 +-
t/unit/test_clocks.py | 89 +
{kombu/tests => t/unit}/test_common.py | 200 +-
{kombu/tests => t/unit}/test_compat.py | 178 +-
t/unit/test_compression.py | 42 +
{kombu/tests => t/unit}/test_connection.py | 505 ++-
.../test_entities.py => t/unit/test_entity.py | 248 +-
t/unit/test_exceptions.py | 11 +
{kombu/tests => t/unit}/test_log.py | 81 +-
t/unit/test_message.py | 44 +
{kombu/tests => t/unit}/test_messaging.py | 347 +-
{kombu/tests => t/unit}/test_mixins.py | 71 +-
{kombu/tests => t/unit}/test_pidbox.py | 131 +-
{kombu/tests => t/unit}/test_pools.py | 109 +-
{kombu/tests => t/unit}/test_serialization.py | 227 +-
{kombu/tests => t/unit}/test_simple.py | 84 +-
.../commands => t/unit/transport}/__init__.py | 0
{kombu/tests => t/unit}/transport/test_SQS.py | 243 +-
{kombu/tests => t/unit}/transport/test_base.py | 104 +-
t/unit/transport/test_consul.py | 81 +
t/unit/transport/test_etcd.py | 67 +
.../tests => t/unit}/transport/test_filesystem.py | 57 +-
.../tests => t/unit}/transport/test_librabbitmq.py | 76 +-
{kombu/tests => t/unit}/transport/test_memory.py | 58 +-
t/unit/transport/test_mongodb.py | 517 +++
{kombu/tests => t/unit}/transport/test_pyamqp.py | 76 +-
{kombu/tests => t/unit}/transport/test_qpid.py | 760 +++--
{kombu/tests => t/unit}/transport/test_redis.py | 611 ++--
t/unit/transport/test_transport.py | 33 +
.../unit/transport/virtual}/__init__.py | 0
.../unit}/transport/virtual/test_base.py | 364 ++-
t/unit/transport/virtual/test_exchange.py | 169 +
{kombu/tests/async => t/unit/utils}/__init__.py | 0
{kombu/tests => t/unit}/utils/test_amq_manager.py | 22 +-
t/unit/utils/test_compat.py | 87 +
{kombu/tests => t/unit}/utils/test_debug.py | 35 +-
t/unit/utils/test_div.py | 49 +
t/unit/utils/test_encoding.py | 105 +
t/unit/utils/test_functional.py | 280 ++
t/unit/utils/test_imports.py | 34 +
t/unit/utils/test_json.py | 92 +
t/unit/utils/test_objects.py | 53 +
t/unit/utils/test_scheduling.py | 103 +
t/unit/utils/test_time.py | 23 +
t/unit/utils/test_url.py | 39 +
t/unit/utils/test_utils.py | 22 +
t/unit/utils/test_uuid.py | 15 +
369 files changed, 15063 insertions(+), 15795 deletions(-)
diff --git a/AUTHORS b/AUTHORS
index a401354..74789ed 100644
--- a/AUTHORS
+++ b/AUTHORS
@@ -1,11 +1,12 @@
=========
AUTHORS
=========
-:order: sorted
+:order: sorted (`.,$!sort -uf`)
Adam Gaca <adam.gaca at oke.pl>
Adam Nelson <adam at varud.com>
Adam Wentz
+Alan Justino <alan.justino at yahoo.com.br>
Alex Koshelev <daevaorn at gmail.com>
Alexandre Bourget <alexandre.bourget at savoirfairelinux.com>
Anastasis Andronidis <anastasis90 at yahoo.gr>
@@ -21,6 +22,7 @@ Bobby Beever <bobby.beever at yahoo.com>
Brian Bernstein
Brian Bouterse <bmbouter at redhat.com>
C Anthony Risinger <anthony+corvisa.com at xtfx.me>
+Chris Erway <cce at appneta.com>
Christophe Chauvet <christophe.chauvet at gmail.com>
Christopher Duryee <cduryee at redhat.com>
Christopher Grebs <cg at webshox.org>
@@ -37,10 +39,11 @@ David Ziegler <david.ziegler at gmail.com>
Dhananjay Nene <dhananjay.nene at gmail.com>
Dmitry Malinovsky <dmalinovsky at thumbtack.net>
Dustin J. Mitchell <dustin at mozilla.com>
+Emmanuel Cazenave <contact at emcaz.fr>
Ephemera <obliviscence+git at gmail.com>
Eric Reynolds <ereynolds at opendns.com>
-Eric Wang <eric1990 at gmail.com>
Fabrice Rabaute <fabrice at expa.com>
+Federico Ficarelli <federico.ficarelli at gmail.com>
Felix Schwarz <felix.schwarz at oss.schwarz.eu>
Felix Yan <felixonmars at archlinux.org>
Fernando Jorge Mota <f.j.mota13 at gmail.com>
@@ -61,7 +64,6 @@ James Turk <james.p.turk at gmail.com>
Jason Cater <jason at ncsfulfillment.com>
Jasper Bryant-Greene <jbg at rf.net.nz>
Jeff Balogh <me at jeffbalogh.org>
-Jeff Ortel <jortel at redhat.com>
Jesper Thomschütz <jesper at jespersaur.com>
Jesse Dhillon <jesse at deva0.net>
John Shuping <jshuping at acm.org>
@@ -70,12 +72,15 @@ John Watson <john at disqus.com>
Jonathan Halcrow <jonathan.halcrow at gmail.com>
Joseph Crosland <jcrosland at flumotion.com>
Joshua Harlow <harlowja at gmail.com>
+Juan Carlos Ferrer <juan.carlos at micronixsolutions.com>
Kai Groner <kai at gronr.com>
Keith Fitzgerald <ghostrocket at me.com>
Kevin McCarthy <me at kevinmccarthy.org>
Kevin McDonald <k3vinmcdonald at gmail.com>
Latitia M. Haskins <lhaskins at jetsonsys.com>
Len Buckens <buckens.len at gmail.com>
+Lorenzo Mancini <lmancini at develer.com>
+Luyun Xie <2304310 at qq.com>
Mahendra M <Mahendra_M at infosys.com>
Marcin Lulek (ergo) <info at webreactor.eu>
Mark Lavin <mlavin at caktusgroup.com>
@@ -86,6 +91,7 @@ mdk <luc.mdk at gmail.com>
Mher Movsisyan <mher.movsisyan at gmail.com>
Michael Barrett <mb at eventbrite.com>
Michael Nelson <michaeln at telesign.com>
+Nathan Van Gheem <vangheem at gmail.com>
Nitzan Miron <bug.assembla at bugbug.me>
Noah Kantrowitz <noah at coderanger.net>
Ollie Walsh <ollie.walsh at geemail.kom>
@@ -100,6 +106,7 @@ Rafael Duran Castaneda <rafadurancastaneda at gmail.com>
Rafal Malinowski <malinowski at red-sky.pl>
Ralf Nyren <ralf-github at nyren.net>
Randy Barlow <rbarlow at redhat.com>
+Raphael Michel <mail at raphaelmichel.de>
Rob Ottaway <robottaway at gmail.com>
Roger Hu <rhu at hearsaycorp.com>
Rumyana Neykova <rumi.neykova at gmail.com>
@@ -111,12 +118,14 @@ Scott Lyons <scottalyons at gmail.com>
Sean Bleier <sebleier at gmail.com>
Sean Creeley <sean.creeley at gmail.com>
Seb Insua <sebastian.insua at saffrondigital.com>
+Sergey Azovskov <last-g at yandex-team.ru>
Sergey Tikhonov <zimbler at gmail.com>
Shane Caraveo <shane at caraveo.com>
Steeve Morin <steeve.morin at gmail.com>
Stefan Eletzhofer <se at nexiles.de>
Stephan Jaekel <steph at rdev.info>
Stephen Day <stevvooe at gmail.com>
+Stuart Axon <stuaxo2 at yahoo.com>
Tareque Hossain
Thomas Johansson <prencher at prencher.dk>
Tobias Schottdorf <tobias at goshippo.com>
@@ -128,5 +137,6 @@ Victor Garcia <victor at tuenti.com>
Viet Hung Nguyen <hvnsweeting at gmail.com>
Vince Gonzalez <vince.gonzalez at gmail.com>
Vincent Driessen <vincent at datafox.nl>
+Wido den Hollander <wido at widodh.nl>
Zach Smith <zmsmith27 at gmail.com>
Zhao Xiaohong <mrluanma at gmail.com>
diff --git a/Changelog b/Changelog
index 7836b3d..fb542e8 100644
--- a/Changelog
+++ b/Changelog
@@ -4,6 +4,401 @@
Change history
================
+.. _version-4.0.2:
+
+4.0.2
+=====
+:release-date: 2016-12-15 03:31 P.M PST
+:release-by: Ask Solem
+
+- Now depends on :mod:`amqp` 2.1.4
+
+ This new version takes advantage of TCP Keepalive settings on Linux,
+ making it better at detecting closed connections, also in failover
+ conditions.
+
+- Redis: Priority was reversed so, e.g. priority 0 became priority 9.
+
+.. _version-4.0.1:
+
+4.0.1
+=====
+:release-date: 2016-12-07 06:00 P.M PST
+:release-by: Ask Solem
+
+- Now depends on :mod:`amqp` 2.1.3
+
+ This new version takes advantage of the new ``TCP_USER_TIMEOUT`` socket option
+ on Linux.
+
+- Producer: Fixed performance degradation when default exchange specified
+ (Issue #651).
+
+- QPid: Switch to using getattr in qpid.Transport.__del__ (Issue #658)
+
+ Contributed by **Patrick Creech**.
+
+- QPid: Now uses monotonic time for timeouts.
+
+- MongoDB: Fixed compatibility with Python 3 (Issue #661).
+
+- Consumer: ``__exit__`` now skips cancelling consumer if connection-related
+ error raised (Issue #670).
+
+- MongoDB: Removes use of natural sort (Issue #638).
+
+ Contributed by **Anton Chaporgin**.
+
+- Fixed wrong keyword argument ``channel`` error (Issue #652).
+
+ Contributed by **Toomore Chiang**.
+
+- Safe argument to ``urllib.quote`` must be bytes on Python 2.x (Issue #645).
+
+- Documentation improvments by:
+
+ - **Carlos Edo**
+ - **Cemre Mengu**
+
+.. _version-4.0:
+
+4.0
+===
+:release-date: 2016-10-28 16:45 P.M UTC
+:release-by: Ask Solem
+
+- Now depends on :mod:`amqp` 2.0.
+
+ The new py-amqp version have been refactored for better performance,
+ using modern Python socket conventions, and API consistency.
+
+- No longer depends on :mod:`anyjson`.
+
+ Kombu will now only choose between :pypi:`simplejson` and the built-in
+ :mod:`json`.
+
+ Using the latest version of simplejson is recommended:
+
+ .. code-block:: console
+
+ $ pip install -U simplejson
+
+- Removed transports that are no longer supported in this version:
+
+ - Django ORM transport
+ - SQLAlchemy ORM transport
+ - Beanstalk transport
+ - ZeroMQ transport
+ - amqplib transport (use pyamqp).
+
+- API Changes
+
+ * Signature of :class:`kombu.Message` now takes body as first argment.
+
+ It used to be ``Message(channel, body=body, **kw)``, but now it's
+ ``Message(body, channel=channel, **kw)``.
+
+ This is unlikey to affect you, as the Kombu API does not have
+ users instantiate messages manually.
+
+- New SQS transport
+
+ Donated by NextDoor, with additional contributions from mdk.
+
+ .. note::
+
+ ``kombu[sqs]`` now depends on :pypi:`pycurl`.
+
+- New Consul transport.
+
+ Contributed by **Wido den Hollander**.
+
+- New etcd transport.
+
+ Contributed by **Stephen Milner**.
+
+- New Qpid transport.
+
+ It was introduced as an experimental transport in Kombu 3.0, but is now
+ mature enough to be fully supported.
+
+ Created and maintained by **Brian Bouterse**.
+
+- Redis: Priority 0 is now lowest, 9 is highest.
+ (**backward incompatible**)
+
+ This to match how priorities in AMQP works.
+
+ Fix contributed by **Alex Koshelev**.
+
+- Redis: Support for Sentinel
+
+ You can point the connection to a list of sentinel URLs like:
+
+ .. code-block:: text
+
+ sentinel://0.0.0.0:26379;sentinel://0.0.0.0:26380/...
+
+ where each sentinel is separated by a `;`. Multiple sentinels are handled
+ by :class:`kombu.Connection` constructor, and placed in the alternative
+ list of servers to connect to in case of connection failure.
+
+ Contributed by **Sergey Azovskov**, and **Lorenzo Mancini**
+
+- RabbitMQ Queue Extensions
+
+ New arguments have been added to :class:`kombu.Queue` that lets
+ you directly and conveniently configure the RabbitMQ queue extensions.
+
+ - ``Queue(expires=20.0)``
+
+ Set queue expiry time in float seconds.
+
+ See :attr:`kombu.Queue.expires`.
+
+ - ``Queue(message_ttl=30.0)``
+
+ Set queue message time-to-live float seconds.
+
+ See :attr:`kombu.Queue.message_ttl`.
+
+ - ``Queue(max_length=1000)``
+
+ Set queue max length (number of messages) as int.
+
+ See :attr:`kombu.Queue.max_length`.
+
+ - ``Queue(max_length_bytes=1000)``
+
+ Set queue max length (message size total in bytes) as int.
+
+ See :attr:`kombu.Queue.max_length_bytes`.
+
+ - ``Queue(max_priority=10)``
+
+ Declare queue to be a priority queue that routes messages
+ based on the ``priority`` field of the message.
+
+ See :attr:`kombu.Queue.max_priority`.
+
+- RabbitMQ: ``Message.ack`` now supports the ``multiple`` argument.
+
+ If multiple is set to True, then all messages received before
+ the message being acked will also be acknowledged.
+
+- ``amqps://`` can now be specified to require SSL (Issue #610).
+
+- ``Consumer.cancel_by_queue`` is now constant time.
+
+- ``Connection.ensure*`` now raises :exc:`kombu.exceptions.OperationalError`.
+
+ Things that can be retried are now reraised as
+ :exc:`kombu.exceptions.OperationalError`.
+
+- Redis: Fixed SSL support.
+
+ Contributed by **Robert Kolba**.
+
+- New ``Queue.consumer_arguments`` can be used for the ability to
+ set consumer priority via ``x-priority``.
+
+ See https://www.rabbitmq.com/consumer-priority.html
+
+ Example:
+
+ .. code-block:: python
+
+ Queue(
+ 'qname',
+ exchange=Exchange('exchange'),
+ routing_key='qname',
+ consumer_arguments={'x-priority': 3},
+ )
+
+- Queue/Exchange: ``no_declare`` option added (also enabled for
+ internal amq. exchanges) (Issue #565).
+
+- JSON serializer now calls ``obj.__json__`` for unsupported types.
+
+ This means you can now define a ``__json__`` method for custom
+ types that can be reduced down to a built-in json type.
+
+ Example:
+
+ .. code-block:: python
+
+ class Person:
+ first_name = None
+ last_name = None
+ address = None
+
+ def __json__(self):
+ return {
+ 'first_name': self.first_name,
+ 'last_name': self.last_name,
+ 'address': self.address,
+ }
+
+- JSON serializer now handles datetimes, Django promise, UUID and Decimal.
+
+- Beanstalk: Priority 0 is now lowest, 9 is highest.
+ (**backward incompatible**)
+
+ This to match how priorities in AMQP works.
+
+ Fix contributed by **Alex Koshelev**.
+
+- Redis: now supports SSL using the ``ssl`` argument to
+ :class:`~kombu.Connection`.
+
+- Redis: Fanout exchanges are no longer visible between vhosts,
+ and fanout messages can be filtered by patterns.
+ (**backward incompatible**)
+
+ It was possible to enable this mode previously using the
+ ``fanout_prefix``, and ``fanout_patterns``
+ transport options, but now these are enabled by default.
+
+ If you want to mix and match producers/consumers running different
+ versions you need to configure your kombu 3.x clients to also enable
+ these options:
+
+ .. code-block:: pycon
+
+ >>> Connection(transport_options={
+ 'fanout_prefix': True,
+ 'fanout_patterns': True,
+ })
+
+- Pidbox: Mailbox new arguments: TTL and expiry.
+
+ Mailbox now supports new arguments for controlling
+ message TTLs and queue expiry, both for the mailbox
+ queue and for reply queues.
+
+ - ``queue_expires`` (float/int seconds).
+ - ``queue_ttl`` (float/int seconds).
+ - ``reply_queue_expires`` (float/int seconds).
+ - ``reply_queue_ttl`` (float/int seconds).
+
+ All take seconds in int/float.
+
+ Contributed by **Alan Justino**.
+
+- Exchange.delivery_mode now defaults to :const:`None`, and the default
+ is instead set by ``Producer.publish``.
+
+- :class:`~kombu.Consumer` now supports a new ``prefetch_count`` argument,
+ which if provided will force the consumer to set an initial prefetch count
+ just before starting.
+
+- Virtual transports now stores ``priority`` as a property, not in
+ ``delivery_info``, to be compatible with AMQP.
+
+- ``reply_to`` argument to ``Producer.publish`` can now be
+ :class:`~kombu.Queue` instance.
+
+- Connection: There's now a new method
+ ``Connection.supports_exchange_type(type)`` that can be used to check if the
+ current transport supports a specific exchange type.
+
+- SQS: Consumers can now read json messages not sent by Kombu.
+
+ Contributed by **Juan Carlos Ferrer**.
+
+- SQS: Will now log the access key used when authentication fails.
+
+ Contributed by **Hank John**.
+
+- Added new :class:`kombu.mixins.ConsumerProducerMixin` for consumers that
+ will also publish messages on a separate connection.
+
+- Messages: Now have a more descriptive ``repr``.
+
+ Contributed by **Joshua Harlow**.
+
+- Async: HTTP client based on curl.
+
+- Async: Now uses `poll` instead of `select` where available.
+
+- MongoDB: Now supports priorities
+
+ Contributed by **Alex Koshelev**.
+
+- Virtual transports now supports multiple queue bindings.
+
+ Contributed by **Federico Ficarelli**.
+
+- Virtual transports now supports the anon exchange.
+
+ If when publishing a message, the exchange argument is set to '' (empty
+ string), the routing_key will be regarded as the destination queue.
+
+ This will bypass the routing table compeltely, and just deliver the
+ message to the queue name specified in the routing key.
+
+- Zookeeper: Transport now uses the built-in suport in kazoo to handle
+ failover when using a list of server names.
+
+ Contributed by **Joshua Harlow**.
+
+- ConsumerMixin.run now passes keyword arguments to .consume.
+
+Deprecations and removals
+-------------------------
+
+- The deprecated method ``Consumer.add_queue_from_dict`` has been removed.
+
+ Use instead:
+
+ .. code-block:: python
+
+ consumer.add_queue(Queue.from_dict(queue_name, **options))
+
+- The deprecated function ``kombu.serialization.encode`` has been removed.
+
+ Use :func:`kombu.serialization.dumps` instead.
+
+- The deprecated function ``kombu.serialization.decode`` has been removed.
+
+ Use :func:`kombu.serialization.loads` instead.
+
+- Removed module ``kombu.syn``
+
+ ``detect_environment`` has been moved to kombu.utils.compat
+
+.. _version-3.0.37:
+
+3.0.37
+======
+:release-date: 2016-10-06 05:00 P.M PDT
+:release-by: Ask Solem
+
+- Connection: Return value of ``.info()`` was no longer JSON serializable,
+ leading to "itertools.cycle object not JSON serializable"
+ errors (Issue #635).
+
+.. _version-3.0.36:
+
+3.0.36
+======
+:release-date: 2016-09-30 03:06 P.M PDT
+:release-by: Ask Solem
+
+- Connection: Fixed bug when cloning connection with alternate urls.
+
+ Fix contributed by Emmanuel Cazenave.
+
+- Redis: Fixed problem with unix socket connections.
+
+ https://github.com/celery/celery/issues/2903
+
+ Fix contributed by Raphael Michel.
+
+- Redis: Fixed compatibility with older redis-py versions (Issue #576).
+
+- Broadcast now retains queue name when being copied/pickled (Issue #578).
+
.. _version-3.0.35:
3.0.35
@@ -135,17 +530,17 @@
3.0.28
======
-:release-date: 2015-10-12 12:00 P.M PDT
+:release-date: 2015-10-12 12:00 PM PDT
:release-by: Ask Solem
-:.. admonition:: Django transport migrations.
+.. admonition:: Django transport migrations.
If you're using Django 1.8 and have already created the
kombu_transport_django tables, you have to run a fake initial migration:
- .. code-block:: pycon
+ .. code-block:: console
- python manage.py migrate kombu_transport_django --fake-initial
+ $ python manage.py migrate kombu_transport_django --fake-initial
- No longer compatible with South by default.
@@ -159,7 +554,7 @@
'kombu.transport.django.south_migrations',
}
-- Keep old South migrations in ``kombu.south.migrations``.
+- Keep old South migrations in ``kombu.transport.django.south_migrations``.
- Now works with Redis < 2.10 again.
@@ -167,12 +562,12 @@
3.0.27
======
-:release-date: 2015-10-09 3:10 P.M PDT
+:release-date: 2015-10-09 3:10 PM PDT
:release-by: Ask Solem
- Now depends on :mod:`amqp` 1.4.7.
-- Fixed libSystem import error on some OS X 10.11 (El Capitan) installations.
+- Fixed libSystem import error on some macOS 10.11 (El Capitan) installations.
Fix contributed by Eric Wang.
@@ -480,13 +875,17 @@
http://www.rabbitmq.com/blog/2014/04/02/breaking-things-with-rabbitmq-3-3/
A new connection property has been added that can be used to detect
- whether the remote server is using this new QoS behavior::
+ whether the remote server is using this new QoS behavior:
+
+ .. code-block:: pycon
>>> Connection('amqp://').qos_behavior_matches_spec
False
so if your application depends on the old semantics you can
- use this to set the ``apply_global`` flag appropriately::
+ use this to set the ``apply_global`` flag appropriately:
+
+ .. code-block:: python
def update_prefetch_count(channel, new_value):
channel.basic_qos(
@@ -573,7 +972,9 @@
messages.
This change is backwards incompatible and must be enabled with
- the ``fanout_patterns`` transport option::
+ the ``fanout_patterns`` transport option:
+
+ .. code-block:: pycon
>>> conn = kombu.Connection('redis://', transport_options={
... 'fanout_patterns': True,
@@ -651,7 +1052,7 @@
- Redis: ``Consumer.cancel()`` is now thread safe.
This fixes an issue when using gevent/eventlet and a
- message is handled after the consumer is cancelled resulting
+ message is handled after the consumer is canceled resulting
in a "message for queue without consumers" error.
- Retry operations would not always respect the interval_start
@@ -677,7 +1078,7 @@
``UNSUBSCRIBE`` command to the server.
This fixes an issue with pidbox where reply messages could be received
- after the consumer was cancelled, giving the ``"message to queue without
+ after the consumer was canceled, giving the ``"message to queue without
consumers"`` error.
- MongoDB: Improved connection string and options handling
@@ -776,7 +1177,9 @@
- Redis: Unix socket URLs can now specify a virtual host by including
it as a query parameter.
- Example URL specifying a virtual host using database number 3::
+ Example URL specifying a virtual host using database number 3:
+
+ .. code-block:: text
redis+socket:///tmp/redis.sock?virtual_host=3
@@ -858,7 +1261,9 @@
This transport option is recommended for all users as it ensures
that broadcast (fanout) messages sent is only seen by the current
- virtual host::
+ virtual host:
+
+ .. code-block:: python
Connection('redis://', transport_options={'fanout_keyprefix': True})
... 43064 lines suppressed ...
--
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/python-modules/packages/kombu.git
More information about the Python-modules-commits
mailing list