summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-02-16 12:03:37 +0000
committerGordon Sim <gsim@apache.org>2007-02-16 12:03:37 +0000
commit3b5328e72148757fb88e77b953016c9d2aabb9d8 (patch)
tree9a5ac2bef0533b6568ce6f3de4a1fc319022e8c6 /python
parentc86c9dc322e71901e88295210b371425204e918b (diff)
downloadqpid-python-3b5328e72148757fb88e77b953016c9d2aabb9d8.tar.gz
Updated failing list for java (some of these result in test suite blocking)
Added better error handling when connection closes without close method git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508377 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
-rw-r--r--python/java_failing.txt8
-rw-r--r--python/qpid/testlib.py5
2 files changed, 12 insertions, 1 deletions
diff --git a/python/java_failing.txt b/python/java_failing.txt
index 70c35cc135..f762b75232 100644
--- a/python/java_failing.txt
+++ b/python/java_failing.txt
@@ -17,3 +17,11 @@ tests.message.MessageTests.test_ack
tests.message.MessageTests.test_get
tests.message.MessageTests.test_qos_prefetch_size
tests.message.MessageTests.test_recover_requeue
+tests.message.MessageTests.test_checkpoint
+
+tests.queue.QueueTests.test_unbind_direct
+tests.queue.QueueTests.test_unbind_topic
+tests.queue.QueueTests.test_unbind_headers
+tests.queue.QueueTests.test_unbind_fanout
+
+tests.broker.BrokerTests.test_ping_pong
diff --git a/python/qpid/testlib.py b/python/qpid/testlib.py
index 836315a4e3..793698ca31 100644
--- a/python/qpid/testlib.py
+++ b/python/qpid/testlib.py
@@ -26,6 +26,7 @@ import qpid.client, qpid.spec
import Queue
from getopt import getopt, GetoptError
from qpid.content import Content
+from qpid.message import Message
def findmodules(root):
"""Find potential python modules under directory root"""
@@ -233,13 +234,15 @@ class TestBase(unittest.TestCase):
"""
self.assertPublishGet(self.consume(queue), exchange, routing_key, properties)
- def assertChannelException(self, expectedCode, message):
+ def assertChannelException(self, expectedCode, message):
+ if not isinstance(message, Message): self.fail("expected channel_close method")
self.assertEqual("channel", message.method.klass.name)
self.assertEqual("close", message.method.name)
self.assertEqual(expectedCode, message.reply_code)
def assertConnectionException(self, expectedCode, message):
+ if not isinstance(message, Message): self.fail("expected connection_close method")
self.assertEqual("connection", message.method.klass.name)
self.assertEqual("close", message.method.name)
self.assertEqual(expectedCode, message.reply_code)