cleanup old irrelevant tests (from 0-10 preview functions)

fix dtx.recover test



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@663675 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 0 insertions, 207 deletions

diff --git a/qpid/python/tests_0-10/message.py b/qpid/python/tests_0-10/message.py
index 8f3d7bdaef..e4dc5566bd 100644
--- a/qpid/python/tests_0-10/message.py
+++ b/qpid/python/tests_0-10/message.py
@@ -304,199 +304,6 @@ class MessageTests(TestBase010):
             self.fail("Got unexpected message: " + extra.body)
         except Empty: None
 
-
-    def test_recover(self):
-        """
-        Test recover behaviour
-        """
-        session = self.session
-        session.queue_declare(queue="queue-a", exclusive=True, auto_delete=True)
-        session.queue_bind(exchange="amq.fanout", queue="queue-a")
-        session.queue_declare(queue="queue-b", exclusive=True, auto_delete=True)
-        session.queue_bind(exchange="amq.fanout", queue="queue-b")
-
-        self.subscribe(queue="queue-a", destination="unconfirmed", confirm_mode=1)
-        self.subscribe(queue="queue-b", destination="confirmed", confirm_mode=0)
-        confirmed = session.incoming("confirmed")
-        unconfirmed = session.incoming("unconfirmed")
-
-        data = ["One", "Two", "Three", "Four", "Five"]
-        for d in data:
-            session.message_transfer(destination="amq.fanout", content=Content(body=d))
-
-        for q in [confirmed, unconfirmed]:
-            for d in data:
-                self.assertEqual(d, q.get(timeout=1).content.body)
-            self.assertEmpty(q)
-
-        session.message_recover(requeue=False)
-
-        self.assertEmpty(confirmed)
-
-        while len(data):
-            msg = None
-            for d in data:
-                msg = unconfirmed.get(timeout=1)
-                self.assertEqual(d, msg.body)
-                self.assertEqual(True, msg.content['redelivered'])
-            self.assertEmpty(unconfirmed)
-            data.remove(msg.body)
-            msg.complete(cumulative=False)
-            session.message_recover(requeue=False)
-
-
-    def test_recover_requeue(self):
-        """
-        Test requeing on recovery
-        """
-        session = self.session
-        session.queue_declare(queue="test-requeue", exclusive=True, auto_delete=True)
-
-        self.subscribe(queue="test-requeue", destination="consumer_tag", confirm_mode=1)
-        queue = session.incoming("consumer_tag")
-
-        session.message_transfer(content=Content(properties={'routing_key' : "test-requeue"}, body="One"))
-        session.message_transfer(content=Content(properties={'routing_key' : "test-requeue"}, body="Two"))
-        session.message_transfer(content=Content(properties={'routing_key' : "test-requeue"}, body="Three"))
-        session.message_transfer(content=Content(properties={'routing_key' : "test-requeue"}, body="Four"))
-        session.message_transfer(content=Content(properties={'routing_key' : "test-requeue"}, body="Five"))
-
-        msg1 = queue.get(timeout=1)
-        msg2 = queue.get(timeout=1)
-        msg3 = queue.get(timeout=1)
-        msg4 = queue.get(timeout=1)
-        msg5 = queue.get(timeout=1)
-
-        self.assertEqual("One", msg1.content.body)
-        self.assertEqual("Two", msg2.content.body)
-        self.assertEqual("Three", msg3.content.body)
-        self.assertEqual("Four", msg4.content.body)
-        self.assertEqual("Five", msg5.content.body)
-
-        msg2.complete(cumulative=True)  #One and Two
-        msg4.complete(cumulative=False)  #Four
-
-        session.message_cancel(destination="consumer_tag")
-
-        #publish a new message
-        session.message_transfer(content=Content(properties={'routing_key' : "test-requeue"}, body="Six"))
-        #requeue unacked messages (Three and Five)
-        session.message_recover(requeue=True)
-
-        self.subscribe(queue="test-requeue", destination="consumer_tag")
-        queue2 = session.incoming("consumer_tag")
-
-        msg3b = queue2.get(timeout=1)
-        msg5b = queue2.get(timeout=1)
-
-        self.assertEqual("Three", msg3b.content.body)
-        self.assertEqual("Five", msg5b.content.body)
-
-        self.assertEqual(True, msg3b.content['redelivered'])
-        self.assertEqual(True, msg5b.content['redelivered'])
-
-        self.assertEqual("Six", queue2.get(timeout=1).content.body)
-
-        try:
-            extra = queue2.get(timeout=1)
-            self.fail("Got unexpected message in second queue: " + extra.content.body)
-        except Empty: None
-        try:
-            extra = queue.get(timeout=1)
-            self.fail("Got unexpected message in original queue: " + extra.content.body)
-        except Empty: None
-
-
-    def test_qos_prefetch_count(self):
-        """
-        Test that the prefetch count specified is honoured
-        """
-        #setup: declare queue and subscribe
-        session = self.session
-        session.queue_declare(queue="test-prefetch-count", exclusive=True, auto_delete=True)
-        subscription = self.subscribe(queue="test-prefetch-count", destination="consumer_tag", confirm_mode=1)
-        queue = session.incoming("consumer_tag")
-
-        #set prefetch to 5:
-        session.message_qos(prefetch_count=5)
-
-        #publish 10 messages:
-        for i in range(1, 11):
-            session.message_transfer(content=Content(properties={'routing_key' : "test-prefetch-count"}, body="Message %d" % i))
-
-        #only 5 messages should have been delivered:
-        for i in range(1, 6):
-            msg = queue.get(timeout=1)
-            self.assertEqual("Message %d" % i, msg.body)
-        try:
-            extra = queue.get(timeout=1)
-            self.fail("Got unexpected 6th message in original queue: " + extra.content.body)
-        except Empty: None
-
-        #ack messages and check that the next set arrive ok:
-        msg.complete()
-
-        for i in range(6, 11):
-            msg = queue.get(timeout=1)
-            self.assertEqual("Message %d" % i, msg.body)
-
-        msg.complete()
-
-        try:
-            extra = queue.get(timeout=1)
-            self.fail("Got unexpected 11th message in original queue: " + extra.content.body)
-        except Empty: None
-
-
-
-    def test_qos_prefetch_size(self):
-        """
-        Test that the prefetch size specified is honoured
-        """
-        #setup: declare queue and subscribe
-        session = self.session
-        session.queue_declare(queue="test-prefetch-size", exclusive=True, auto_delete=True)
-        subscription = self.subscribe(queue="test-prefetch-size", destination="consumer_tag", confirm_mode=1)
-        queue = session.incoming("consumer_tag")
-
-        #set prefetch to 50 bytes (each message is 9 or 10 bytes):
-        session.message_qos(prefetch_size=50)
-
-        #publish 10 messages:
-        for i in range(1, 11):
-            session.message_transfer(content=Content(properties={'routing_key' : "test-prefetch-size"}, body="Message %d" % i))
-
-        #only 5 messages should have been delivered (i.e. 45 bytes worth):
-        for i in range(1, 6):
-            msg = queue.get(timeout=1)
-            self.assertEqual("Message %d" % i, msg.body)
-
-        try:
-            extra = queue.get(timeout=1)
-            self.fail("Got unexpected 6th message in original queue: " + extra.content.body)
-        except Empty: None
-
-        #ack messages and check that the next set arrive ok:
-        msg.complete()
-
-        for i in range(6, 11):
-            msg = queue.get(timeout=1)
-            self.assertEqual("Message %d" % i, msg.body)
-
-        msg.complete()
-
-        try:
-            extra = queue.get(timeout=1)
-            self.fail("Got unexpected 11th message in original queue: " + extra.content.body)
-        except Empty: None
-
-        #make sure that a single oversized message still gets delivered
-        large = "abcdefghijklmnopqrstuvwxyz"
-        large = large + "-" + large;
-        session.message_transfer(content=Content(properties={'routing_key' : "test-prefetch-size"}, body=large))
-        msg = queue.get(timeout=1)
-        self.assertEqual(large, msg.body)
-
     def test_reject(self):
         session = self.session
         session.queue_declare(queue = "q", exclusive=True, auto_delete=True, alternate_exchange="amq.fanout")
@@ -972,20 +779,6 @@ class MessageTests(TestBase010):
         #ensure there are no other messages
         self.assertEmpty(queueC)
 
-    def test_no_size(self):
-        self.queue_declare(queue = "q", exclusive=True, auto_delete=True)
-
-        ssn = self.session
-        ssn.message_transfer(content=SizelessContent(properties={'routing_key' : "q"}, body="message-body"))
-
-        ssn.message_subscribe(queue = "q", destination="d", confirm_mode = 0)
-        ssn.message_flow(unit = ssn.credit_unit.message, value = 0xFFFFFFFF, destination = "d")
-        ssn.message_flow(unit = ssn.credit_unit.byte, value = 0xFFFFFFFF, destination = "d")
-
-        queue = session.incoming("d")
-        msg = queue.get(timeout = 3)
-        self.assertEquals("message-body", msg.body)
-
     def test_empty_body(self):
         session = self.session
         session.queue_declare(queue="xyz", exclusive=True, auto_delete=True)