diff -Nru kombu-3.0.30/Changelog kombu-3.0.33/Changelog --- kombu-3.0.30/Changelog 2015-12-07 08:33:14.000000000 +0000 +++ kombu-3.0.33/Changelog 2016-01-09 02:36:24.000000000 +0000 @@ -4,11 +4,48 @@ Change history ================ +.. _version-3.0.33: + +3.0.33 +====== +:release-date: 2016-01-08 06:36 P.M PST +:release-by: Ask Solem + +- Now depends on :mod:`amqp` 1.4.9. + +- Redis: Fixed problem with auxilliary connections causing the main + consumer connection to be closed (Issue #550). + +- Qpid: No longer uses threads to operate, to ensure compatibility with + all environments (Issue #531). + +.. _version-3.0.32: + +3.0.32 +====== +:release-date: 2015-12-16 02:29 P.M PST +:release-by: Ask Solem + +- Redis: Fixed bug introduced in 3.0.31 where the redis transport always + connects to localhost, regardless of host setting. + +.. _version-3.0.31: + +3.0.31 +====== +:release-date: 2015-12-16 12:00 P.M PST +:release-by: Ask Solem + +- Redis: Fixed bug introduced in 3.0.30 where socket was prematurely + disconnected. + +- Hub: Removed debug logging message: "Deregistered fd..." (Issue #549). + .. _version-3.0.30: 3.0.30 ====== -:release-date: 2015-12-07 12:28 A.M PDT +:release-date: 2015-12-07 12:28 A.M PST :release-by: Ask Solem - Fixes compatiblity with uuid in Python 2.7.11 and 3.5.1. diff -Nru kombu-3.0.30/debian/changelog kombu-3.0.33/debian/changelog --- kombu-3.0.30/debian/changelog 2015-12-14 21:06:11.000000000 +0000 +++ kombu-3.0.33/debian/changelog 2016-03-04 14:07:41.000000000 +0000 @@ -1,17 +1,36 @@ -kombu (3.0.30-1ubuntu1~cloud0) trusty-mitaka; urgency=medium +kombu (3.0.33-1ubuntu2~cloud0) trusty-mitaka; urgency=medium - * New upstream release for the Ubuntu Cloud Archive. + * New update for the Ubuntu Cloud Archive. - -- Openstack Ubuntu Testing Bot Mon, 14 Dec 2015 21:06:11 +0000 + -- Openstack Ubuntu Testing Bot Fri, 04 Mar 2016 14:07:41 +0000 -kombu (3.0.30-1ubuntu1) xenial; urgency=low +kombu (3.0.33-1ubuntu2) xenial; urgency=medium + + * d/control: Ensure that requirement for amqp >= 1.4.9 is set + consistently across (Build-)Depends (LP: #1546430). + + -- James Page Fri, 04 Mar 2016 12:53:20 +0000 + +kombu (3.0.33-1ubuntu1) xenial; urgency=low [ Corey Bryant ] * Merge from Debian unstable. Remaining changes: - debian/control: Drop build depends (and therefore suggests) on python-couchdb, as it is not in Ubuntu main. - -- Corey Bryant Mon, 14 Dec 2015 15:07:41 -0500 + -- Corey Bryant Wed, 17 Feb 2016 09:07:56 -0500 + +kombu (3.0.33-1) unstable; urgency=medium + + * New upstream release. + + -- Brian May Tue, 19 Jan 2016 13:12:11 +1100 + +kombu (3.0.32-1) unstable; urgency=low + + * New upstream release. + + -- Michael Fladischer Sat, 02 Jan 2016 16:57:52 +0100 kombu (3.0.30-1) unstable; urgency=medium diff -Nru kombu-3.0.30/debian/control kombu-3.0.33/debian/control --- kombu-3.0.30/debian/control 2015-12-07 18:42:59.000000000 +0000 +++ kombu-3.0.33/debian/control 2016-03-04 12:45:00.000000000 +0000 @@ -8,7 +8,7 @@ Build-Depends: debhelper (>= 9), dh-python, python-all, - python-amqp (>= 1.4.6), + python-amqp (>= 1.4.9), python-anyjson (>= 0.3.3), python-beanstalkc, python-boto, @@ -26,7 +26,7 @@ python-unittest2, python-yaml, python3-all, - python3-amqp, + python3-amqp (>= 1.4.9), python3-anyjson (>= 0.3.3), python3-django, python3-mock, @@ -48,7 +48,7 @@ Package: python-kombu Architecture: all -Depends: python-amqp (>= 1.4.6), +Depends: python-amqp (>= 1.4.9), python-anyjson (>= 0.3.3), ${misc:Depends}, ${python:Depends} @@ -77,7 +77,7 @@ Package: python3-kombu Architecture: all -Depends: python3-amqp (>= 1.4.6), +Depends: python3-amqp (>= 1.4.9), python3-anyjson (>= 0.3.3), ${misc:Depends}, ${python3:Depends} diff -Nru kombu-3.0.30/debian/.git-dpm kombu-3.0.33/debian/.git-dpm --- kombu-3.0.30/debian/.git-dpm 2015-12-07 10:11:07.000000000 +0000 +++ kombu-3.0.33/debian/.git-dpm 2016-02-17 13:59:43.000000000 +0000 @@ -1,11 +1,11 @@ # see git-dpm(1) from git-dpm package -5b991a909b078067a9702ab1ce7669a88da71f1d -5b991a909b078067a9702ab1ce7669a88da71f1d -a2b1b2e701b7299f7dc4c5dc4ad4662cb9ddfa67 -a2b1b2e701b7299f7dc4c5dc4ad4662cb9ddfa67 -kombu_3.0.30.orig.tar.gz -6c2abf37c32048a1db940a94d85349533eb9c1c1 -380706 +854fb06c0873ed6c6126aa486914ccb50d54e401 +854fb06c0873ed6c6126aa486914ccb50d54e401 +5bdc5a4c59a815f0c189f1276b53bf0f8c5d1092 +5bdc5a4c59a815f0c189f1276b53bf0f8c5d1092 +kombu_3.0.33.orig.tar.gz +2d75380949ee87e549c8fcb48821ad73108aebc1 +379423 debianTag="debian/%e%v" patchedTag="patched/%e%v" upstreamTag="upstream/%e%u" diff -Nru kombu-3.0.30/debian/patches/remove_logo.patch kombu-3.0.33/debian/patches/remove_logo.patch --- kombu-3.0.30/debian/patches/remove_logo.patch 2015-12-07 18:42:59.000000000 +0000 +++ kombu-3.0.33/debian/patches/remove_logo.patch 2016-02-17 13:59:43.000000000 +0000 @@ -1,4 +1,4 @@ -From 5b991a909b078067a9702ab1ce7669a88da71f1d Mon Sep 17 00:00:00 2001 +From 854fb06c0873ed6c6126aa486914ccb50d54e401 Mon Sep 17 00:00:00 2001 From: Michael Fladischer Date: Thu, 8 Oct 2015 09:29:19 -0700 Subject: Remove github-hosted logo from documentation @@ -27,7 +27,7 @@ 'sourcelink.html', 'searchbox.html'], } diff --git a/docs/introduction.rst b/docs/introduction.rst -index 3371801..936f21b 100644 +index 891984b..603208c 100644 --- a/docs/introduction.rst +++ b/docs/introduction.rst @@ -324,7 +324,3 @@ License diff -Nru kombu-3.0.30/docs/changelog.rst kombu-3.0.33/docs/changelog.rst --- kombu-3.0.30/docs/changelog.rst 2015-12-07 08:33:14.000000000 +0000 +++ kombu-3.0.33/docs/changelog.rst 2016-01-09 02:36:24.000000000 +0000 @@ -4,11 +4,48 @@ Change history ================ +.. _version-3.0.33: + +3.0.33 +====== +:release-date: 2016-01-08 06:36 P.M PST +:release-by: Ask Solem + +- Now depends on :mod:`amqp` 1.4.9. + +- Redis: Fixed problem with auxilliary connections causing the main + consumer connection to be closed (Issue #550). + +- Qpid: No longer uses threads to operate, to ensure compatibility with + all environments (Issue #531). + +.. _version-3.0.32: + +3.0.32 +====== +:release-date: 2015-12-16 02:29 P.M PST +:release-by: Ask Solem + +- Redis: Fixed bug introduced in 3.0.31 where the redis transport always + connects to localhost, regardless of host setting. + +.. _version-3.0.31: + +3.0.31 +====== +:release-date: 2015-12-16 12:00 P.M PST +:release-by: Ask Solem + +- Redis: Fixed bug introduced in 3.0.30 where socket was prematurely + disconnected. + +- Hub: Removed debug logging message: "Deregistered fd..." (Issue #549). + .. _version-3.0.30: 3.0.30 ====== -:release-date: 2015-12-07 12:28 A.M PDT +:release-date: 2015-12-07 12:28 A.M PST :release-by: Ask Solem - Fixes compatiblity with uuid in Python 2.7.11 and 3.5.1. diff -Nru kombu-3.0.30/docs/introduction.rst kombu-3.0.33/docs/introduction.rst --- kombu-3.0.30/docs/introduction.rst 2015-12-07 08:34:05.000000000 +0000 +++ kombu-3.0.33/docs/introduction.rst 2016-01-09 02:12:59.000000000 +0000 @@ -4,7 +4,7 @@ kombu - Messaging library for Python ======================================== -:Version: 3.0.30 +:Version: 3.0.33 `Kombu` is a messaging library for Python. diff -Nru kombu-3.0.30/kombu/async/hub.py kombu-3.0.33/kombu/async/hub.py --- kombu-3.0.30/kombu/async/hub.py 2015-12-07 08:27:58.000000000 +0000 +++ kombu-3.0.33/kombu/async/hub.py 2016-01-08 22:35:32.000000000 +0000 @@ -34,10 +34,6 @@ Received unknown event %r for fd %r, please contact support!\ """ -W_EVENT_UNREGISTERED = """\ -Deregistered fd %r from event loop without registered callbacks.\ -""" - class Stop(BaseException): """Stops the event loop.""" @@ -324,7 +320,6 @@ pass if cb is None: - logger.info(W_EVENT_UNREGISTERED, fd) self.remove(fd) continue diff -Nru kombu-3.0.30/kombu/five.py kombu-3.0.33/kombu/five.py --- kombu-3.0.30/kombu/five.py 2015-12-07 08:27:23.000000000 +0000 +++ kombu-3.0.33/kombu/five.py 2016-01-08 22:35:32.000000000 +0000 @@ -41,13 +41,12 @@ import platform SYSTEM = platform.system() - has_ctypes = True try: import ctypes - except ImportError: - has_ctypes = False + except ImportError: # pragma: no cover + ctypes = None # noqa - if SYSTEM == 'Darwin' and has_ctypes: + if SYSTEM == 'Darwin' and ctypes is not None: from ctypes.util import find_library libSystem = ctypes.CDLL(find_library('libSystem.dylib')) CoreServices = ctypes.CDLL(find_library('CoreServices'), @@ -61,7 +60,7 @@ def _monotonic(): return absolute_to_nanoseconds(mach_absolute_time()) * 1e-9 - elif SYSTEM == 'Linux' and has_ctypes: + elif SYSTEM == 'Linux' and ctypes is not None: # from stackoverflow: # questions/1205722/how-do-i-get-monotonic-time-durations-in-python import os diff -Nru kombu-3.0.30/kombu/__init__.py kombu-3.0.33/kombu/__init__.py --- kombu-3.0.30/kombu/__init__.py 2015-12-07 08:33:26.000000000 +0000 +++ kombu-3.0.33/kombu/__init__.py 2016-01-09 02:12:55.000000000 +0000 @@ -11,7 +11,7 @@ 'version_info_t', ('major', 'minor', 'micro', 'releaselevel', 'serial'), ) -VERSION = version_info_t(3, 0, 30, '', '') +VERSION = version_info_t(3, 0, 33, '', '') __version__ = '{0.major}.{0.minor}.{0.micro}{0.releaselevel}'.format(VERSION) __author__ = 'Ask Solem' __contact__ = 'ask@celeryproject.org' diff -Nru kombu-3.0.30/kombu/tests/transport/test_qpid.py kombu-3.0.33/kombu/tests/transport/test_qpid.py --- kombu-3.0.30/kombu/tests/transport/test_qpid.py 2015-12-07 08:27:23.000000000 +0000 +++ kombu-3.0.33/kombu/tests/transport/test_qpid.py 2016-01-08 22:35:32.000000000 +0000 @@ -4,7 +4,6 @@ import ssl import socket import sys -import threading import time from collections import Callable @@ -16,7 +15,7 @@ from kombu.five import Empty, keys, range, monotonic from kombu.transport.qpid import (AuthenticationFailure, Channel, Connection, ConnectionError, Message, NotFound, QoS, - ReceiversMonitor, Transport) + Transport) from kombu.transport.virtual import Base64 from kombu.tests.case import Case, Mock, case_no_pypy, case_no_python3 from kombu.tests.case import patch @@ -855,9 +854,9 @@ self.mock_queue = Mock() def tearDown(self): - self.mock__has_queue.stop() - self.mock__size.stop() - self.mock__delete.stop() + self.patch__has_queue.stop() + self.patch__size.stop() + self.patch__delete.stop() super(TestChannelQueueDelete, self).tearDown() def test_checks_if_queue_exists(self): @@ -1397,164 +1396,6 @@ @case_no_python3 @case_no_pypy -class ReceiversMonitorTestBase(Case): - - def setUp(self): - self.mock_session = Mock() - self.mock_w = Mock() - self.monitor = ReceiversMonitor(self.mock_session, self.mock_w) - - -@case_no_python3 -@case_no_pypy -class TestReceiversMonitorType(ReceiversMonitorTestBase): - - def test_qpid_messaging_receivers_monitor_subclass_of_threading(self): - self.assertIsInstance(self.monitor, threading.Thread) - - -@case_no_python3 -@case_no_pypy -class TestReceiversMonitorInit(ReceiversMonitorTestBase): - - def setUp(self): - thread___init___str = QPID_MODULE + '.threading.Thread.__init__' - self.patch_parent___init__ = patch(thread___init___str) - self.mock_Thread___init__ = self.patch_parent___init__.start() - super(TestReceiversMonitorInit, self).setUp() - - def tearDown(self): - self.patch_parent___init__.stop() - - def test_qpid_messaging_receivers_monitor_init_saves_session(self): - self.assertIs(self.monitor._session, self.mock_session) - - def test_qpid_messaging_receivers_monitor_init_saves_fd(self): - self.assertIs(self.monitor._w_fd, self.mock_w) - - def test_qpid_messaging_Receivers_monitor_init_calls_parent__init__(self): - self.mock_Thread___init__.assert_called_once_with() - - -@case_no_python3 -@case_no_pypy -class TestReceiversMonitorRun(ReceiversMonitorTestBase): - - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - def test_receivers_monitor_run_calls_monitor_receivers( - self, mock_sleep, mock_monitor_receivers): - mock_sleep.side_effect = BreakOutException() - with self.assertRaises(BreakOutException): - self.monitor.run() - mock_monitor_receivers.assert_called_once_with() - - @patch(QPID_MODULE + '.SessionClosed', new=QpidException) - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - def test_receivers_monitor_run_exits_on_session_closed( - self, mock_sleep, mock_monitor_receivers): - mock_monitor_receivers.side_effect = QpidException() - try: - self.monitor.run() - except Exception: - self.fail('No exception should be raised here') - mock_monitor_receivers.assert_called_once_with() - mock_sleep.has_calls([]) - - @patch.object(Transport, 'connection_errors', new=(BreakOutException, )) - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - @patch(QPID_MODULE + '.logger') - def test_receivers_monitors_run_calls_logs_exception_and_sleeps( - self, mock_logger, mock_sleep, mock_monitor_receivers): - exc_to_raise = IOError() - mock_monitor_receivers.side_effect = exc_to_raise - mock_sleep.side_effect = BreakOutException() - with self.assertRaises(BreakOutException): - self.monitor.run() - mock_logger.error.assert_called_once_with(exc_to_raise, exc_info=1) - mock_sleep.assert_called_once_with(10) - - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - def test_receivers_monitor_run_loops_when_exception_is_raised( - self, mock_sleep, mock_monitor_receivers): - def return_once_raise_on_second_call(*args): - mock_sleep.side_effect = BreakOutException() - mock_sleep.side_effect = return_once_raise_on_second_call - with self.assertRaises(BreakOutException): - self.monitor.run() - mock_monitor_receivers.has_calls([call(), call()]) - - @patch.object(Transport, 'recoverable_connection_errors', - new=(QpidException, )) - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - @patch(QPID_MODULE + '.logger') - @patch(QPID_MODULE + '.os.write') - @patch(QPID_MODULE + '.sys.exc_info') - def test_receivers_monitor_exits_when_recoverable_exception_raised( - self, mock_sys_exc_info, mock_os_write, mock_logger, mock_sleep, - mock_monitor_receivers): - mock_monitor_receivers.side_effect = QpidException() - mock_sleep.side_effect = BreakOutException() - self.monitor.run() - self.assertFalse(mock_logger.error.called) - - @patch.object(Transport, 'recoverable_connection_errors', - new=(QpidException, )) - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - @patch(QPID_MODULE + '.logger') - @patch(QPID_MODULE + '.os.write') - def test_receivers_monitor_saves_exception_when_recoverable_exc_raised( - self, mock_os_write, mock_logger, mock_sleep, - mock_monitor_receivers): - mock_monitor_receivers.side_effect = QpidException() - mock_sleep.side_effect = BreakOutException() - self.monitor.run() - self.assertIs( - self.mock_session.saved_exception, - mock_monitor_receivers.side_effect, - ) - - @patch.object(Transport, 'recoverable_connection_errors', - new=(QpidException, )) - @patch.object(ReceiversMonitor, 'monitor_receivers') - @patch(QPID_MODULE + '.time.sleep') - @patch(QPID_MODULE + '.logger') - @patch(QPID_MODULE + '.os.write') - @patch(QPID_MODULE + '.sys.exc_info') - def test_receivers_monitor_writes_e_to_pipe_when_recoverable_exc_raised( - self, mock_sys_exc_info, mock_os_write, mock_logger, mock_sleep, - mock_monitor_receivers): - mock_monitor_receivers.side_effect = QpidException() - mock_sleep.side_effect = BreakOutException() - self.monitor.run() - mock_os_write.assert_called_once_with(self.mock_w, 'e') - - -@case_no_python3 -@case_no_pypy -class TestReceiversMonitorMonitorReceivers(ReceiversMonitorTestBase): - - def test_receivers_monitor_monitor_receivers_calls_next_receivers(self): - self.mock_session.next_receiver.side_effect = BreakOutException() - with self.assertRaises(BreakOutException): - self.monitor.monitor_receivers() - self.mock_session.next_receiver.assert_called_once_with() - - def test_receivers_monitor_monitor_receivers_writes_to_fd(self): - with patch(QPID_MODULE + '.os.write') as mock_os_write: - mock_os_write.side_effect = BreakOutException() - with self.assertRaises(BreakOutException): - self.monitor.monitor_receivers() - mock_os_write.assert_called_once_with(self.mock_w, '0') - - -@case_no_python3 -@case_no_pypy @disable_runtime_dependency_check class TestTransportInit(Case): @@ -1699,12 +1540,6 @@ self.transport = Transport(self.client) self.mock_conn = Mock() self.transport.Connection = self.mock_conn - path_to_mock = QPID_MODULE + '.ReceiversMonitor' - self.patcher = patch(path_to_mock) - self.mock_ReceiverMonitor = self.patcher.start() - - def tearDown(self): - self.patcher.stop() def test_transport_establish_conn_new_option_overwrites_default(self): self.client.userid = 'new-userid' @@ -1863,22 +1698,7 @@ new_conn = self.transport.establish_connection() self.assertIs(new_conn, self.mock_conn.return_value) - def test_transport_establish_conn_creates_ReceiversMonitor(self): - self.transport.establish_connection() - self.mock_ReceiverMonitor.assert_called_once_with( - self.transport.session, self.transport._w, - ) - - def test_transport_establish_conn_daemonizes_thread(self): - self.transport.establish_connection() - self.assertTrue(self.mock_ReceiverMonitor.return_value.daemon) - - def test_transport_establish_conn_starts_thread(self): - self.transport.establish_connection() - new_receiver_monitor = self.mock_ReceiverMonitor.return_value - new_receiver_monitor.start.assert_called_once_with() - - def test_transport_establish_conn_ignores_hostname_if_not_localhost(self): + def test_transport_establish_conn_uses_hostname_if_not_default(self): self.client.hostname = 'some_other_hostname' self.transport.establish_connection() self.mock_conn.assert_called_once_with( @@ -1889,6 +1709,14 @@ transport='tcp', ) + def test_transport_sets_qpid_message_received_handler(self): + self.transport.establish_connection() + qpid_conn = self.mock_conn.return_value.get_qpid_connection + new_mock_session = qpid_conn.return_value.session.return_value + mock_set_callback = new_mock_session.set_message_received_handler + expected_callback = self.transport._qpid_session_ready + mock_set_callback.assert_called_once_with(expected_callback) + @case_no_python3 @case_no_pypy @@ -1941,6 +1769,24 @@ @case_no_python3 @case_no_pypy @disable_runtime_dependency_check +class TestTransportQpidSessionReady(Case): + + def setUp(self): + self.patch_a = patch(QPID_MODULE + '.os.write') + self.mock_os_write = self.patch_a.start() + self.transport = Transport(Mock()) + + def tearDown(self): + self.patch_a.stop() + + def test_transport__qpid_session_ready_writes_symbol_to_fd(self): + self.transport._qpid_session_ready() + self.mock_os_write.assert_called_once_with(self.transport._w, '0') + + +@case_no_python3 +@case_no_pypy +@disable_runtime_dependency_check class TestTransportOnReadable(Case): def setUp(self): @@ -1952,6 +1798,7 @@ def tearDown(self): self.patch_a.stop() + self.patch_b.stop() def test_transport_on_readable_reads_symbol_from_fd(self): self.transport.on_readable(Mock(), Mock()) @@ -1971,16 +1818,6 @@ with self.assertRaises(IOError): self.transport.on_readable(Mock(), Mock()) - def test_transport_on_readable_reads_e_off_of_pipe_raises_exc_info(self): - self.transport.session = Mock() - try: - raise IOError() - except Exception as error: - self.transport.session.saved_exception = error - self.mock_os_read.return_value = 'e' - with self.assertRaises(IOError): - self.transport.on_readable(Mock(), Mock()) - @case_no_python3 @case_no_pypy diff -Nru kombu-3.0.30/kombu/tests/transport/test_redis.py kombu-3.0.33/kombu/tests/transport/test_redis.py --- kombu-3.0.30/kombu/tests/transport/test_redis.py 2015-12-07 08:27:23.000000000 +0000 +++ kombu-3.0.33/kombu/tests/transport/test_redis.py 2016-01-09 02:35:11.000000000 +0000 @@ -5,6 +5,7 @@ from anyjson import dumps, loads from collections import defaultdict +from contextlib import contextmanager from itertools import count from kombu import Connection, Exchange, Queue, Consumer, Producer @@ -18,6 +19,23 @@ ) +class JSONEqual(object): + # The order in which a dict is serialized to json depends on the hashseed + # so we have this to support json in .assert_has_call*. + + def __init__(self, expected): + self.expected = expected + + def __eq__(self, other): + return loads(other) == loads(self.expected) + + def __str__(self): + return self.expected + + def __repr__(self): + return '(json)%r' % (self.expected,) + + class _poll(eventio._select): def register(self, fd, flags): @@ -171,6 +189,9 @@ return self + def __repr__(self): + return '=0.3.3 -amqp>=1.4.7,<2.0 +amqp>=1.4.9,<2.0 [sqlalchemy] sqlalchemy diff -Nru kombu-3.0.30/PKG-INFO kombu-3.0.33/PKG-INFO --- kombu-3.0.30/PKG-INFO 2015-12-07 08:37:48.000000000 +0000 +++ kombu-3.0.33/PKG-INFO 2016-01-09 02:38:13.000000000 +0000 @@ -1,6 +1,6 @@ Metadata-Version: 1.1 Name: kombu -Version: 3.0.30 +Version: 3.0.33 Summary: Messaging library for Python Home-page: http://kombu.readthedocs.org Author: Ask Solem @@ -12,7 +12,7 @@ kombu - Messaging library for Python ======================================== - :Version: 3.0.30 + :Version: 3.0.33 `Kombu` is a messaging library for Python. diff -Nru kombu-3.0.30/README.rst kombu-3.0.33/README.rst --- kombu-3.0.30/README.rst 2015-12-07 08:34:05.000000000 +0000 +++ kombu-3.0.33/README.rst 2016-01-09 02:12:59.000000000 +0000 @@ -4,7 +4,7 @@ kombu - Messaging library for Python ======================================== -:Version: 3.0.30 +:Version: 3.0.33 `Kombu` is a messaging library for Python. diff -Nru kombu-3.0.30/requirements/default.txt kombu-3.0.33/requirements/default.txt --- kombu-3.0.30/requirements/default.txt 2015-12-07 08:27:23.000000000 +0000 +++ kombu-3.0.33/requirements/default.txt 2016-01-09 02:06:52.000000000 +0000 @@ -1,2 +1,2 @@ anyjson>=0.3.3 -amqp>=1.4.7,<2.0 +amqp>=1.4.9,<2.0