From 0eac760be17bba07698ba02999d5be53c5a08c1f Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Fri, 25 Jun 2010 18:12:28 +0000 Subject: added support for x-amqp-0-10.{app-id,content-encoding,routing-key} git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@958055 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/tests/messaging/__init__.py | 14 ++++++++++---- python/qpid/tests/messaging/message.py | 4 +++- 2 files changed, 13 insertions(+), 5 deletions(-) (limited to 'python/qpid/tests') diff --git a/python/qpid/tests/messaging/__init__.py b/python/qpid/tests/messaging/__init__.py index 2c1dce9ad8..a160f38531 100644 --- a/python/qpid/tests/messaging/__init__.py +++ b/python/qpid/tests/messaging/__init__.py @@ -88,16 +88,22 @@ class Base(Test): self.assertEchos(expected, messages, redelivered) return messages - def diff(self, m1, m2): + def diff(self, m1, m2, excluded_properties=()): result = {} for attr in ("id", "subject", "user_id", "reply_to", "correlation_id", "durable", "priority", "ttl", - "redelivered", "properties", "content_type", - "content"): + "redelivered", "content_type", "content"): a1 = getattr(m1, attr) a2 = getattr(m2, attr) if a1 != a2: result[attr] = (a1, a2) + p1 = dict(m1.properties) + p2 = dict(m2.properties) + for ep in excluded_properties: + p1.pop(ep, None) + p2.pop(ep, None) + if p1 != p2: + result["properties"] = (p1, p2) return result def assertEcho(self, msg, echo, redelivered=False): @@ -108,7 +114,7 @@ class Base(Test): echo = echo.content assert msg == echo, "expected %s, got %s" % (msg, echo) else: - delta = self.diff(msg, echo) + delta = self.diff(msg, echo, ("x-amqp-0-10.routing-key",)) mttl, ettl = delta.pop("ttl", (0, 0)) if redelivered: assert echo.redelivered, \ diff --git a/python/qpid/tests/messaging/message.py b/python/qpid/tests/messaging/message.py index 2ca1fbf155..91aab5fb35 100644 --- a/python/qpid/tests/messaging/message.py +++ b/python/qpid/tests/messaging/message.py @@ -85,7 +85,9 @@ class MessageEchoTests(Base): "key6": -3.14, "key7": ["one", 2, 3.14], "key8": [], - "key9": {"sub-key0": 3}} + "key9": {"sub-key0": 3}, + "x-amqp-0-10.app-id": "test-app-id", + "x-amqp-0-10.content-encoding": "test-content-encoding"} def testMapContent(self): self.check(Message(MessageEchoTests.TEST_MAP)) -- cgit v1.2.1