Hello community, here is the log from the commit of package python-kombu for openSUSE:Factory checked in at 2013-04-02 12:52:54 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Comparing /work/SRC/openSUSE:Factory/python-kombu (Old) and /work/SRC/openSUSE:Factory/.python-kombu.new (New) ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "python-kombu", Maintainer is "[email protected]" Changes: -------- --- /work/SRC/openSUSE:Factory/python-kombu/python-kombu.changes 2013-03-18 07:10:54.000000000 +0100 +++ /work/SRC/openSUSE:Factory/.python-kombu.new/python-kombu.changes 2013-04-02 12:52:57.000000000 +0200 @@ -1,0 +2,24 @@ +Thu Mar 21 19:57:35 UTC 2013 - [email protected] + +- Update to 2.5.8: + - Now depends on amqp 1.0.10 which fixes a Python 3 compatibility + error. + - Redis: Fixed a possible race condition (Issue #171). + - Redis: Ack emulation/visibility_timeout can now be disabled + using a transport option. + Ack emulation adds quite a lot of overhead to ensure data is safe + even in the event of an unclean shutdown. If data loss do not worry + you there is now an `ack_emulation` transport option you can use + to disable it: + Connection('redis://', transport_options={'ack_emulation': False}) + - SQS: Fixed boto v2.7 compatibility (Issue #207). + - Exchange: Should not try to re-declare default exchange ("") + (Issue #209). + - SQS: Long polling is now disabled by default as it was not + implemented correctly, resulting in long delays between receiving + messages (Issue #202). + - Fixed Python 2.6 incompatibility depending on exc.errno + being available. + Fix contributed by Ephemera. + +------------------------------------------------------------------- --- /work/SRC/openSUSE:Factory/python-kombu/python3-kombu.changes 2013-03-18 07:10:54.000000000 +0100 +++ /work/SRC/openSUSE:Factory/.python-kombu.new/python3-kombu.changes 2013-04-02 12:52:57.000000000 +0200 @@ -1,0 +2,24 @@ +Thu Mar 21 19:59:14 UTC 2013 - [email protected] + +- Update to 2.5.8: + - Now depends on amqp 1.0.10 which fixes a Python 3 compatibility + error. + - Redis: Fixed a possible race condition (Issue #171). + - Redis: Ack emulation/visibility_timeout can now be disabled + using a transport option. + Ack emulation adds quite a lot of overhead to ensure data is safe + even in the event of an unclean shutdown. If data loss do not worry + you there is now an `ack_emulation` transport option you can use + to disable it: + Connection('redis://', transport_options={'ack_emulation': False}) + - SQS: Fixed boto v2.7 compatibility (Issue #207). + - Exchange: Should not try to re-declare default exchange ("") + (Issue #209). + - SQS: Long polling is now disabled by default as it was not + implemented correctly, resulting in long delays between receiving + messages (Issue #202). + - Fixed Python 2.6 incompatibility depending on exc.errno + being available. + Fix contributed by Ephemera. + +------------------------------------------------------------------- Old: ---- kombu-2.5.7.tar.gz New: ---- kombu-2.5.8.tar.gz ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Other differences: ------------------ ++++++ python-kombu.spec ++++++ --- /var/tmp/diff_new_pack.aK9D9Z/_old 2013-04-02 12:52:58.000000000 +0200 +++ /var/tmp/diff_new_pack.aK9D9Z/_new 2013-04-02 12:52:58.000000000 +0200 @@ -17,7 +17,7 @@ Name: python-kombu -Version: 2.5.7 +Version: 2.5.8 Release: 0 Summary: AMQP Messaging Framework for Python License: BSD-3-Clause ++++++ python3-kombu.spec ++++++ --- /var/tmp/diff_new_pack.aK9D9Z/_old 2013-04-02 12:52:58.000000000 +0200 +++ /var/tmp/diff_new_pack.aK9D9Z/_new 2013-04-02 12:52:58.000000000 +0200 @@ -17,7 +17,7 @@ Name: python3-kombu -Version: 2.5.7 +Version: 2.5.8 Release: 0 Summary: AMQP Messaging Framework for Python License: BSD-2-Clause ++++++ accept-newer-amqp-versions.diff ++++++ --- /var/tmp/diff_new_pack.aK9D9Z/_old 2013-04-02 12:52:58.000000000 +0200 +++ /var/tmp/diff_new_pack.aK9D9Z/_new 2013-04-02 12:52:58.000000000 +0200 @@ -4,17 +4,18 @@ +++ kombu.egg-info/requires.txt @@ -1,2 +1,2 @@ anyjson>=0.3.3 --amqp>=1.0.9,<1.1.0 +-amqp>=1.0.10,<1.1.0 +\ No newline at end of file ++amqp>=1.0.10 \ No newline at end of file -+amqp>=1.0.9 Index: requirements/default.txt =================================================================== --- requirements/default.txt.orig +++ requirements/default.txt @@ -1,2 +1,2 @@ anyjson>=0.3.3 --amqp>=1.0.9,<1.1.0 -+amqp>=1.0.9 +-amqp>=1.0.10,<1.1.0 ++amqp>=1.0.10 Index: setup.cfg =================================================================== --- setup.cfg.orig ++++++ kombu-2.5.7.tar.gz -> kombu-2.5.8.tar.gz ++++++ diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/AUTHORS new/kombu-2.5.8/AUTHORS --- old/kombu-2.5.7/AUTHORS 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/AUTHORS 2013-03-21 15:01:12.000000000 +0100 @@ -26,6 +26,7 @@ David Gelvin <[email protected]> David Strauss <[email protected]> David Ziegler <[email protected]> +Ephemera <[email protected]> Flavio [FlaPer87] Percoco Premoli <[email protected]> Florian Munz <[email protected]> Franck Cuny <[email protected]> diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/Changelog new/kombu-2.5.8/Changelog --- old/kombu-2.5.7/Changelog 2013-03-08 13:47:47.000000000 +0100 +++ new/kombu-2.5.8/Changelog 2013-03-21 17:05:26.000000000 +0100 @@ -4,6 +4,40 @@ Change history ================ +.. _version-2.5.8: + +2.5.8 +===== +:release-date: 2013-03-21 04:00 P.M UTC + +- Now depends on :mod:`amqp` 1.0.10 which fixes a Python 3 compatibility error. + +- Redis: Fixed a possible race condition (Issue #171). + +- Redis: Ack emulation/visibility_timeout can now be disabled + using a transport option. + + Ack emulation adds quite a lot of overhead to ensure data is safe + even in the event of an unclean shutdown. If data loss do not worry + you there is now an `ack_emulation` transport option you can use + to disable it:: + + Connection('redis://', transport_options={'ack_emulation': False}) + +- SQS: Fixed :mod:`boto` v2.7 compatibility (Issue #207). + +- Exchange: Should not try to re-declare default exchange (``""``) + (Issue #209). + +- SQS: Long polling is now disabled by default as it was not + implemented correctly, resulting in long delays between receiving + messages (Issue #202). + +- Fixed Python 2.6 incompatibility depending on ``exc.errno`` + being available. + + Fix contributed by Ephemera. + .. _version-2.5.7: 2.5.7 diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/PKG-INFO new/kombu-2.5.8/PKG-INFO --- old/kombu-2.5.7/PKG-INFO 2013-03-08 13:49:29.000000000 +0100 +++ new/kombu-2.5.8/PKG-INFO 2013-03-21 17:27:24.000000000 +0100 @@ -1,6 +1,6 @@ Metadata-Version: 1.1 Name: kombu -Version: 2.5.7 +Version: 2.5.8 Summary: Messaging Framework for Python Home-page: http://kombu.readthedocs.org Author: Ask Solem @@ -10,7 +10,7 @@ kombu - Messaging Framework for Python ======================================== - :Version: 2.5.7 + :Version: 2.5.8 `Kombu` is a messaging framework for Python. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/README new/kombu-2.5.8/README --- old/kombu-2.5.7/README 2013-03-08 13:48:48.000000000 +0100 +++ new/kombu-2.5.8/README 2013-03-21 17:05:44.000000000 +0100 @@ -2,7 +2,7 @@ kombu - Messaging Framework for Python ======================================== -:Version: 2.5.7 +:Version: 2.5.8 `Kombu` is a messaging framework for Python. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/README.rst new/kombu-2.5.8/README.rst --- old/kombu-2.5.7/README.rst 2013-03-08 13:48:48.000000000 +0100 +++ new/kombu-2.5.8/README.rst 2013-03-21 17:05:44.000000000 +0100 @@ -2,7 +2,7 @@ kombu - Messaging Framework for Python ======================================== -:Version: 2.5.7 +:Version: 2.5.8 `Kombu` is a messaging framework for Python. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/docs/changelog.rst new/kombu-2.5.8/docs/changelog.rst --- old/kombu-2.5.7/docs/changelog.rst 2013-03-08 13:47:47.000000000 +0100 +++ new/kombu-2.5.8/docs/changelog.rst 2013-03-21 17:05:26.000000000 +0100 @@ -4,6 +4,40 @@ Change history ================ +.. _version-2.5.8: + +2.5.8 +===== +:release-date: 2013-03-21 04:00 P.M UTC + +- Now depends on :mod:`amqp` 1.0.10 which fixes a Python 3 compatibility error. + +- Redis: Fixed a possible race condition (Issue #171). + +- Redis: Ack emulation/visibility_timeout can now be disabled + using a transport option. + + Ack emulation adds quite a lot of overhead to ensure data is safe + even in the event of an unclean shutdown. If data loss do not worry + you there is now an `ack_emulation` transport option you can use + to disable it:: + + Connection('redis://', transport_options={'ack_emulation': False}) + +- SQS: Fixed :mod:`boto` v2.7 compatibility (Issue #207). + +- Exchange: Should not try to re-declare default exchange (``""``) + (Issue #209). + +- SQS: Long polling is now disabled by default as it was not + implemented correctly, resulting in long delays between receiving + messages (Issue #202). + +- Fixed Python 2.6 incompatibility depending on ``exc.errno`` + being available. + + Fix contributed by Ephemera. + .. _version-2.5.7: 2.5.7 diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/docs/introduction.rst new/kombu-2.5.8/docs/introduction.rst --- old/kombu-2.5.7/docs/introduction.rst 2013-03-08 13:48:48.000000000 +0100 +++ new/kombu-2.5.8/docs/introduction.rst 2013-03-21 17:05:44.000000000 +0100 @@ -2,7 +2,7 @@ kombu - Messaging Framework for Python ======================================== -:Version: 2.5.7 +:Version: 2.5.8 `Kombu` is a messaging framework for Python. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/__init__.py new/kombu-2.5.8/kombu/__init__.py --- old/kombu-2.5.7/kombu/__init__.py 2013-03-08 13:47:50.000000000 +0100 +++ new/kombu-2.5.8/kombu/__init__.py 2013-03-21 17:05:44.000000000 +0100 @@ -1,7 +1,7 @@ """Messaging Framework for Python""" from __future__ import absolute_import -VERSION = (2, 5, 7) +VERSION = (2, 5, 8) __version__ = '.'.join(map(str, VERSION[0:3])) + ''.join(VERSION[3:]) __author__ = 'Ask Solem' __contact__ = '[email protected]' diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/connection.py new/kombu-2.5.8/kombu/connection.py --- old/kombu-2.5.7/kombu/connection.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/connection.py 2013-03-21 15:01:12.000000000 +0100 @@ -24,7 +24,9 @@ from .log import get_logger from .transport import get_transport_cls, supports_librabbitmq from .utils import cached_property, retry_over_time, shufflecycle -from .utils.compat import OrderedDict, LifoQueue as _LifoQueue, next +from .utils.compat import ( + OrderedDict, LifoQueue as _LifoQueue, next, get_errno, +) from .utils.functional import promise from .utils.url import parse_url @@ -290,7 +292,7 @@ self.more_to_read = False return False except socket.error, exc: - if exc.errno in (errno.EAGAIN, errno.EINTR): + if get_errno(exc) in (errno.EAGAIN, errno.EINTR): self.more_to_read = False return False raise diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/entity.py new/kombu-2.5.8/kombu/entity.py --- old/kombu-2.5.7/kombu/entity.py 2013-01-17 13:02:34.000000000 +0100 +++ new/kombu-2.5.8/kombu/entity.py 2013-03-21 16:26:34.000000000 +0100 @@ -150,13 +150,12 @@ response will not be waited for. Default is :const:`False`. """ - return self.channel.exchange_declare(exchange=self.name, - type=self.type, - durable=self.durable, - auto_delete=self.auto_delete, - arguments=self.arguments, - nowait=nowait, - passive=passive) + if self.name: + return self.channel.exchange_declare( + exchange=self.name, type=self.type, durable=self.durable, + auto_delete=self.auto_delete, arguments=self.arguments, + nowait=nowait, passive=passive, + ) def bind_to(self, exchange='', routing_key='', arguments=None, nowait=False, **kwargs): diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/tests/test_simple.py new/kombu-2.5.8/kombu/tests/test_simple.py --- old/kombu-2.5.7/kombu/tests/test_simple.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/tests/test_simple.py 2013-03-21 16:50:21.000000000 +0100 @@ -26,6 +26,8 @@ def setUp(self): if not self.abstract: self.connection = Connection(transport='memory') + with self.connection.channel() as channel: + channel.exchange_declare('amq.direct') self.q = self.Queue(None, no_ack=True) def tearDown(self): diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/tests/transport/test_base.py new/kombu-2.5.8/kombu/tests/transport/test_base.py --- old/kombu-2.5.7/kombu/tests/transport/test_base.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/tests/transport/test_base.py 2013-03-21 16:41:59.000000000 +0100 @@ -1,7 +1,7 @@ from __future__ import absolute_import from __future__ import with_statement -from kombu import Connection, Consumer, Producer, Queue +from kombu import Connection, Consumer, Exchange, Producer, Queue from kombu.transport.base import Message, StdChannel, Transport from kombu.tests.utils import TestCase @@ -17,7 +17,7 @@ self.conn.connection.state.clear() def test_Consumer(self): - q = Queue('foo') + q = Queue('foo', Exchange('foo')) print(self.channel.queues) cons = self.channel.Consumer(q) self.assertIsInstance(cons, Consumer) diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/transport/SQS.py new/kombu-2.5.8/kombu/transport/SQS.py --- old/kombu-2.5.7/kombu/transport/SQS.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/transport/SQS.py 2013-03-21 16:11:14.000000000 +0100 @@ -14,6 +14,7 @@ from anyjson import loads, dumps +import boto from boto import exception from boto import sdb as _sdb from boto import sqs as _sqs @@ -35,6 +36,15 @@ CHARS_REPLACE_TABLE[0x2e] = 0x2d # '.' -> '-' +def maybe_int(x): + try: + return int(x) + except ValueError: + return x +BOTO_VERSION = tuple(maybe_int(part) for part in boto.__version__.split('.')) +W_LONG_POLLING = BOTO_VERSION >= (2, 8) + + class Table(Domain): """Amazon SimpleDB domain describing the message routing table.""" # caches queues already bound, so we don't have to declare them again. @@ -123,7 +133,7 @@ default_region = 'us-east-1' default_visibility_timeout = 1800 # 30 minutes. # 20 seconds is the max value currently supported by SQS. - default_wait_time_seconds = 20 + default_wait_time_seconds = 1 # disabled: see Issue #198 domain_format = 'kombu%(vhost)s' _sdb = None _sqs = None @@ -229,7 +239,10 @@ def _get(self, queue): """Try to retrieve a single message off ``queue``.""" q = self._new_queue(queue) - rs = q.get_messages(1, wait_time_seconds=self.wait_time_seconds) + if W_LONG_POLLING: + rs = q.get_messages(1, wait_time_seconds=self.wait_time_seconds) + else: # boto < 2.8 + rs = q.get_messages(1) if rs: m = rs[0] payload = loads(rs[0].get_body()) diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/transport/redis.py new/kombu-2.5.8/kombu/transport/redis.py --- old/kombu-2.5.7/kombu/transport/redis.py 2013-03-08 13:46:07.000000000 +0100 +++ new/kombu-2.5.8/kombu/transport/redis.py 2013-03-21 17:02:36.000000000 +0100 @@ -314,6 +314,7 @@ _in_poll = False _in_listen = False _fanout_queues = {} + ack_emulation = True unacked_key = 'unacked' unacked_index_key = 'unacked_index' unacked_mutex_key = 'unacked_mutex' @@ -327,7 +328,8 @@ from_transport_options = ( virtual.Channel.from_transport_options + - ('unacked_key', + ('ack_emulation', + 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', @@ -342,6 +344,9 @@ super_ = super(Channel, self) super_.__init__(*args, **kwargs) + if not self.ack_emulation: # disable visibility timeout + self.QoS = virtual.QoS + self._queue_cycle = [] self.Client = self._get_client() self.ResponseError = self._get_response_error() @@ -642,17 +647,6 @@ super(KombuRedis, self).__init__(*args, **kwargs) self.connection = self.connection_pool.get_connection('_') - def execute_command(self, *args, **options): - conn = self.connection - command_name = args[0] - try: - conn.send_command(*args) - return self.parse_response(conn, command_name, **options) - except redis.ConnectionError: - conn.disconnect() - conn.send_command(*args) - return self.parse_response(conn, command_name, **options) - return KombuRedis @contextmanager diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/transport/virtual/__init__.py new/kombu-2.5.8/kombu/transport/virtual/__init__.py --- old/kombu-2.5.7/kombu/transport/virtual/__init__.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/transport/virtual/__init__.py 2013-03-21 17:00:23.000000000 +0100 @@ -196,6 +196,9 @@ finally: state.restored = True + def restore_visible(self, start=0, num=10, interval=10): + pass + class Message(base.Message): diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/utils/compat.py new/kombu-2.5.8/kombu/utils/compat.py --- old/kombu-2.5.7/kombu/utils/compat.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/utils/compat.py 2013-03-21 15:01:12.000000000 +0100 @@ -33,6 +33,23 @@ raise return args[0] +############## socket.error.errno ############################################ + + +def get_errno(exc): + """:exc:`socket.error` and :exc:`IOError` first got + the ``.errno`` attribute in Py2.7""" + try: + return exc.errno + except AttributeError: + try: + # e.args = (errno, reason) + if isinstance(exc.args, tuple) and len(exc.args) == 2: + return exc.args[0] + except AttributeError: + pass + return 0 + ############## collections.OrderedDict ####################################### try: from collections import OrderedDict diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu/utils/eventio.py new/kombu-2.5.8/kombu/utils/eventio.py --- old/kombu-2.5.7/kombu/utils/eventio.py 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/kombu/utils/eventio.py 2013-03-21 15:01:12.000000000 +0100 @@ -45,6 +45,8 @@ from kombu.syn import detect_environment +from .compat import get_errno + __all__ = ['poll'] READ = POLL_READ = 0x001 @@ -52,19 +54,6 @@ ERR = POLL_ERR = 0x008 | 0x010 -def get_errno(exc): - try: - return exc.errno - except AttributeError: - try: - # e.args = (errno, reason) - if isinstance(exc.args, tuple) and len(exc.args) == 2: - return exc.args[0] - except AttributeError: - pass - return 0 - - class Poller(object): def poll(self, timeout): diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu.egg-info/PKG-INFO new/kombu-2.5.8/kombu.egg-info/PKG-INFO --- old/kombu-2.5.7/kombu.egg-info/PKG-INFO 2013-03-08 13:49:22.000000000 +0100 +++ new/kombu-2.5.8/kombu.egg-info/PKG-INFO 2013-03-21 17:27:18.000000000 +0100 @@ -1,6 +1,6 @@ Metadata-Version: 1.1 Name: kombu -Version: 2.5.7 +Version: 2.5.8 Summary: Messaging Framework for Python Home-page: http://kombu.readthedocs.org Author: Ask Solem @@ -10,7 +10,7 @@ kombu - Messaging Framework for Python ======================================== - :Version: 2.5.7 + :Version: 2.5.8 `Kombu` is a messaging framework for Python. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/kombu.egg-info/requires.txt new/kombu-2.5.8/kombu.egg-info/requires.txt --- old/kombu-2.5.7/kombu.egg-info/requires.txt 2013-03-08 13:49:22.000000000 +0100 +++ new/kombu-2.5.8/kombu.egg-info/requires.txt 2013-03-21 17:27:18.000000000 +0100 @@ -1,2 +1,2 @@ anyjson>=0.3.3 -amqp>=1.0.9,<1.1.0 \ No newline at end of file +amqp>=1.0.10,<1.1.0 \ No newline at end of file diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/kombu-2.5.7/requirements/default.txt new/kombu-2.5.8/requirements/default.txt --- old/kombu-2.5.7/requirements/default.txt 2013-03-08 13:42:37.000000000 +0100 +++ new/kombu-2.5.8/requirements/default.txt 2013-03-21 16:31:01.000000000 +0100 @@ -1,2 +1,2 @@ anyjson>=0.3.3 -amqp>=1.0.9,<1.1.0 +amqp>=1.0.10,<1.1.0 -- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
