10 files changed, 187 insertions, 0 deletions
diff --git a/t/oldint/tests/__init__.py b/t/oldint/tests/__init__.py
new file mode 100644
index 00000000..094b08e0
--- /dev/null
+++ b/t/oldint/tests/__init__.py
@@ -0,0 +1,8 @@
+
+import os
+import sys
+
+sys.path.insert(0, os.path.join(os.getcwd(), os.pardir))
+print(sys.path[0])
+sys.path.insert(0, os.getcwd())
+print(sys.path[0])
diff --git a/t/oldint/tests/test_SLMQ.py b/t/oldint/tests/test_SLMQ.py
new file mode 100644
index 00000000..8428f7d1
--- /dev/null
+++ b/t/oldint/tests/test_SLMQ.py
@@ -0,0 +1,19 @@
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_environ('SLMQ_ACCOUNT')
+@skip.unless_environ('SL_USERNAME')
+@skip.unless_environ('SL_API_KEY')
+@skip.unless_environ('SLMQ_HOST')
+@skip.unless_environ('SLMQ_SECURE')
+class test_SLMQ(transport.TransportCase):
+    transport = 'SLMQ'
+    prefix = 'slmq'
+    event_loop_max = 100
+    message_size_limit = 4192
+    reliable_purge = False
+    #: does not guarantee FIFO order, even in simple cases.
+    suppress_disorder_warning = True
diff --git a/t/oldint/tests/test_SQS.py b/t/oldint/tests/test_SQS.py
new file mode 100644
index 00000000..571cff24
--- /dev/null
+++ b/t/oldint/tests/test_SQS.py
@@ -0,0 +1,20 @@
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_environ('AWS_ACCESS_KEY_ID')
+@skip.unless_environ('AWS_SECRET_ACCESS_KEY')
+@skip.unless_module('boto')
+class test_SQS(transport.TransportCase):
+    transport = 'SQS'
+    prefix = 'sqs'
+    event_loop_max = 100
+    message_size_limit = 4192  # SQS max body size / 2.
+    reliable_purge = False
+    #: does not guarantee FIFO order, even in simple cases
+    suppress_disorder_warning = True
+
+    def after_connect(self, connection):
+        connection.channel().sqs
diff --git a/t/oldint/tests/test_amqp.py b/t/oldint/tests/test_amqp.py
new file mode 100644
index 00000000..f7aa762e
--- /dev/null
+++ b/t/oldint/tests/test_amqp.py
@@ -0,0 +1,7 @@
+
+from funtests import transport
+
+
+class test_pyamqp(transport.TransportCase):
+    transport = 'pyamqp'
+    prefix = 'pyamqp'
diff --git a/t/oldint/tests/test_librabbitmq.py b/t/oldint/tests/test_librabbitmq.py
new file mode 100644
index 00000000..41a21b3c
--- /dev/null
+++ b/t/oldint/tests/test_librabbitmq.py
@@ -0,0 +1,10 @@
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_module('librabbitmq')
+class test_librabbitmq(transport.TransportCase):
+    transport = 'librabbitmq'
+    prefix = 'librabbitmq'
diff --git a/t/oldint/tests/test_mongodb.py b/t/oldint/tests/test_mongodb.py
new file mode 100644
index 00000000..495208c7
--- /dev/null
+++ b/t/oldint/tests/test_mongodb.py
@@ -0,0 +1,73 @@
+from kombu import Consumer, Producer, Exchange, Queue
+from kombu.utils.compat import nested
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_module('pymongo')
+class test_mongodb(transport.TransportCase):
+    transport = 'mongodb'
+    prefix = 'mongodb'
+    event_loop_max = 100
+
+    def after_connect(self, connection):
+        connection.channel().client  # evaluate connection.
+        self.c = self.connection   # shortcut
+
+    def test_fanout(self, name='test_mongodb_fanout'):
+        if not self.verify_alive():
+            return
+        c = self.connection
+        self.e = Exchange(name, type='fanout')
+        self.q = Queue(name, exchange=self.e, routing_key=name)
+        self.q2 = Queue(name + '2', exchange=self.e, routing_key=name + '2')
+
+        channel = c.default_channel
+        producer = Producer(channel, self.e)
+        consumer1 = Consumer(channel, self.q)
+        consumer2 = Consumer(channel, self.q2)
+        self.q2(channel).declare()
+
+        for i in range(10):
+            producer.publish({'foo': i}, routing_key=name)
+        for i in range(10):
+            producer.publish({'foo': i}, routing_key=name + '2')
+
+        _received1 = []
+        _received2 = []
+
+        def callback1(message_data, message):
+            _received1.append(message)
+            message.ack()
+
+        def callback2(message_data, message):
+            _received2.append(message)
+            message.ack()
+
+        consumer1.register_callback(callback1)
+        consumer2.register_callback(callback2)
+
+        with nested(consumer1, consumer2):
+
+            while 1:
+                if len(_received1) + len(_received2) == 20:
+                    break
+                c.drain_events(timeout=60)
+        self.assertEqual(len(_received1) + len(_received2), 20)
+
+        # queue.delete
+        for i in range(10):
+            producer.publish({'foo': i}, routing_key=name)
+        self.assertTrue(self.q(channel).get())
+        self.q(channel).delete()
+        self.q(channel).declare()
+        self.assertIsNone(self.q(channel).get())
+
+        # queue.purge
+        for i in range(10):
+            producer.publish({'foo': i}, routing_key=name + '2')
+        self.assertTrue(self.q2(channel).get())
+        self.q2(channel).purge()
+        self.assertIsNone(self.q2(channel).get())
diff --git a/t/oldint/tests/test_pyamqp.py b/t/oldint/tests/test_pyamqp.py
new file mode 100644
index 00000000..f7aa762e
--- /dev/null
+++ b/t/oldint/tests/test_pyamqp.py
@@ -0,0 +1,7 @@
+
+from funtests import transport
+
+
+class test_pyamqp(transport.TransportCase):
+    transport = 'pyamqp'
+    prefix = 'pyamqp'
diff --git a/t/oldint/tests/test_qpid.py b/t/oldint/tests/test_qpid.py
new file mode 100644
index 00000000..a5c9141d
--- /dev/null
+++ b/t/oldint/tests/test_qpid.py
@@ -0,0 +1,10 @@
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_module('qpid.messaging')
+class test_qpid(transport.TransportCase):
+    transport = 'qpid'
+    prefix = 'qpid'
diff --git a/t/oldint/tests/test_redis.py b/t/oldint/tests/test_redis.py
new file mode 100644
index 00000000..610b0149
--- /dev/null
+++ b/t/oldint/tests/test_redis.py
@@ -0,0 +1,19 @@
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_module('redis')
+class test_redis(transport.TransportCase):
+    transport = 'redis'
+    prefix = 'redis'
+
+    def after_connect(self, connection):
+        client = connection.channel().client
+        client.info()
+
+    def test_cannot_connect_raises_connection_error(self):
+        conn = self.get_connection(port=65534)
+        with self.assertRaises(conn.connection_errors):
+            conn.connect()
diff --git a/t/oldint/tests/test_zookeeper.py b/t/oldint/tests/test_zookeeper.py
new file mode 100644
index 00000000..150c4a35
--- /dev/null
+++ b/t/oldint/tests/test_zookeeper.py
@@ -0,0 +1,14 @@
+
+from funtests import transport
+
+from kombu.tests.case import skip
+
+
+@skip.unless_module('kazoo')
+class test_zookeeper(transport.TransportCase):
+    transport = 'zookeeper'
+    prefix = 'zookeeper'
+    event_loop_max = 100
+
+    def after_connect(self, connection):
+        connection.channel().client