Connection: Support for multiple URLs and failover.

Either::

    Connection(['amqp://foo', 'amqp://bar'])

or:

    Connection('amqp://foo;amqp://bar')

Fixes celery/celery#616

1 files changed, 12 insertions, 0 deletions

diff --git a/kombu/utils/compat.py b/kombu/utils/compat.py
index c1b3cec4..d695728c 100644
--- a/kombu/utils/compat.py
+++ b/kombu/utils/compat.py
@@ -10,6 +10,18 @@ Helps compatibility with older Python versions.
 """
 import sys
 
+############## __builtins__.next #############################################
+try:
+    next = next
+except NameError:
+    def next(it, *args):  # noqa
+        try:
+            return it.__next__()
+        except StopIteration:
+            if not args:
+                raise
+            return args[0]
+
 ############## collections.OrderedDict #######################################
 
 import weakref