Unified
Split
Showing
with
688 additions
and 848 deletions.
- +1 −0 .gitignore
- +21 −13 .travis.yml
- +2 −0 AUTHORS
- +3 −3 README.rst
- +17 −0 appveyor.yml
- BIN docs/images/kombu.jpg
- BIN docs/images/kombusmall.jpg
- +1 −1 examples/hello_consumer.py
- +95 −131 kombu/async/aws/connection.py
- +14 −17 kombu/async/aws/ext.py
- +0 −22 kombu/async/aws/sqs/__init__.py
- +28 −32 kombu/async/aws/sqs/connection.py
- +4 −27 kombu/async/aws/sqs/ext.py
- +20 −31 kombu/async/aws/sqs/message.py
- +1 −2 kombu/async/aws/sqs/queue.py
- +9 −0 kombu/async/http/base.py
- +7 −10 kombu/async/http/curl.py
- +6 −2 kombu/common.py
- +2 −2 kombu/compat.py
- +1 −1 kombu/connection.py
- +1 −1 kombu/entity.py
- +3 −2 kombu/messaging.py
- +22 −6 kombu/simple.py
- +126 −88 kombu/transport/SQS.py
- +2 −1 kombu/transport/librabbitmq.py
- +2 −1 kombu/transport/redis.py
- +1 −1 kombu/transport/virtual/exchange.py
- +11 −7 kombu/transport/zookeeper.py
- +1 −1 requirements/extras/sqs.txt
- +1 −1 requirements/funtest.txt
- +1 −1 requirements/pkgutils.txt
- +1 −0 requirements/test-ci.txt
- +1 −0 setup.py
- +1 −1 t/integration/tests/test_SQS.py
- +1 −1 t/unit/async/aws/case.py
- +37 −36 t/unit/async/aws/sqs/test_connection.py
- +0 −37 t/unit/async/aws/sqs/test_message.py
- +0 −34 t/unit/async/aws/sqs/test_sqs.py
- +1 −1 t/unit/async/aws/test_aws.py
- +49 −222 t/unit/async/aws/test_connection.py
- +20 −1 t/unit/test_common.py
- +121 −108 t/unit/transport/test_SQS.py
- +0 −1 t/unit/transport/test_base.py
- +14 −0 t/unit/transport/test_redis.py
- +36 −0 t/unit/transport/test_zookeeper.py
- +3 −2 tox.ini
| @@ -30,3 +30,4 @@ dump.rdb | ||
| htmlcov/ | ||
| test.db | ||
| coverage.xml | ||
| venv/ | ||
| @@ -1,21 +1,29 @@ | ||
| language: python | ||
| sudo: false | ||
| cache: false | ||
| python: | ||
| - '3.5' | ||
| cache: pip | ||
| env: | ||
| global: | ||
| PYTHONUNBUFFERED=yes | ||
| matrix: | ||
| - TOXENV=2.7 | ||
| - TOXENV=3.4 | ||
| - TOXENV=3.5 | ||
| - TOXENV=pypy | ||
| - TOXENV=flake8 | ||
| - TOXENV=flakeplus | ||
| - TOXENV=apicheck | ||
| - TOXENV=pydocstyle | ||
| - TOXENV=cov | ||
| matrix: | ||
| include: | ||
| - python: 2.7 | ||
| env: TOXENV=2.7 | ||
| - python: 3.4 | ||
| env: TOXENV=3.4 | ||
| - python: 3.5 | ||
| env: TOXENV=3.5 | ||
| - python: 3.6 | ||
| env: TOXENV=3.6 | ||
| - python: pypy | ||
| env: TOXENV=pypy | ||
| - env: TOXENV=flake8 | ||
| - env: TOXENV=flakeplus | ||
| - env: TOXENV=apicheck | ||
| - env: TOXENV=pydocstyle | ||
| - env: TOXENV=cov | ||
| install: travis_retry pip install -U tox | ||
| script: tox -v -- -v | ||
| after_success: | ||
| @@ -37,6 +37,7 @@ David Gelvin <david.gelvin@gmail.com> | ||
| David Strauss <david@davidstrauss.net> | ||
| David Ziegler <david.ziegler@gmail.com> | ||
| Dhananjay Nene <dhananjay.nene@gmail.com> | ||
| Dima Kurguzov <koorgoo@gmail.com> | ||
| Dmitry Malinovsky <dmalinovsky@thumbtack.net> | ||
| Dustin J. Mitchell <dustin@mozilla.com> | ||
| Emmanuel Cazenave <contact@emcaz.fr> | ||
| @@ -108,6 +109,7 @@ Ralf Nyren <ralf-github@nyren.net> | ||
| Randy Barlow <rbarlow@redhat.com> | ||
| Raphael Michel <mail@raphaelmichel.de> | ||
| Rob Ottaway <robottaway@gmail.com> | ||
| Robert Kopaczewski <rk@23doors.com> | ||
| Roger Hu <rhu@hearsaycorp.com> | ||
| Rumyana Neykova <rumi.neykova@gmail.com> | ||
| Rune Halvorsen <runeh@opera.com> | ||
| @@ -124,7 +124,7 @@ Kombu is using Sphinx, and the latest documentation can be found here: | ||
| Quick overview | ||
| -------------- | ||
| :: | ||
| .. code:: python | ||
| from kombu import Connection, Exchange, Queue | ||
| @@ -169,7 +169,7 @@ Quick overview | ||
| Or handle channels manually: | ||
| :: | ||
| .. code:: python | ||
| with connection.channel() as channel: | ||
| producer = Producer(channel, ...) | ||
| @@ -179,7 +179,7 @@ Or handle channels manually: | ||
| All objects can be used outside of with statements too, | ||
| just remember to close the objects after use: | ||
| :: | ||
| .. code:: python | ||
| from kombu import Connection, Consumer, Producer | ||
| @@ -20,6 +20,14 @@ environment: | ||
| PYTHON_VERSION: "3.4.x" | ||
| PYTHON_ARCH: "32" | ||
| - PYTHON: "C:\\Python35" | ||
| PYTHON_VERSION: "3.5.x" | ||
| PYTHON_ARCH: "32" | ||
| - PYTHON: "C:\\Python36" | ||
| PYTHON_VERSION: "3.6.x" | ||
| PYTHON_ARCH: "32" | ||
| - PYTHON: "C:\\Python27-x64" | ||
| PYTHON_VERSION: "2.7.x" | ||
| PYTHON_ARCH: "64" | ||
| @@ -30,6 +38,15 @@ environment: | ||
| PYTHON_ARCH: "64" | ||
| WINDOWS_SDK_VERSION: "v7.1" | ||
| - PYTHON: "C:\\Python35-x64" | ||
| PYTHON_VERSION: "3.5.x" | ||
| PYTHON_ARCH: "64" | ||
| WINDOWS_SDK_VERSION: "v7.1" | ||
| - PYTHON: "C:\\Python36-x64" | ||
| PYTHON_VERSION: "3.6.x" | ||
| PYTHON_ARCH: "64" | ||
| WINDOWS_SDK_VERSION: "v7.1" | ||
| init: | ||
| - "ECHO %PYTHON% %PYTHON_VERSION% %PYTHON_ARCH%" | ||
Binary file not shown.
Binary file not shown.
| @@ -1,6 +1,6 @@ | ||
| from __future__ import absolute_import, unicode_literals, print_function | ||
| from kombu import Connection | ||
| from kombu import Connection # noqa | ||
| with Connection('amqp://guest:guest@localhost:5672//') as conn: | ||
Oops, something went wrong.