summaryrefslogtreecommitdiff
path: root/python/tests
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-05-07 16:03:08 +0000
committerRafael H. Schloming <rhs@apache.org>2008-05-07 16:03:08 +0000
commitb10ca140b947991309044155485d86ce8c9cb8ce (patch)
tree95814740b9bd25dcd7e56fda164166a4dfcf1c49 /python/tests
parentf25c7ddb3d6a0c6a2bd5df700b3a612ba101f0e1 (diff)
downloadqpid-python-b10ca140b947991309044155485d86ce8c9cb8ce.tar.gz
QPID-979: added convenience accessors for headers
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@654158 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/tests')
-rw-r--r--python/tests/datatypes.py53
1 files changed, 53 insertions, 0 deletions
diff --git a/python/tests/datatypes.py b/python/tests/datatypes.py
index e4d6723d95..5c6ee82283 100644
--- a/python/tests/datatypes.py
+++ b/python/tests/datatypes.py
@@ -18,6 +18,8 @@
#
from unittest import TestCase
+from qpid.testlib import testrunner
+from qpid.spec010 import load
from qpid.datatypes import *
class RangedSetTest(TestCase):
@@ -109,3 +111,54 @@ class UUIDTest(TestCase):
u = uuid4()
for i in xrange(1024):
assert u != uuid4()
+
+class MessageTest(TestCase):
+
+ def setUp(self):
+ self.spec = load(testrunner.get_spec_file("amqp.0-10-qpid-errata.xml"))
+ self.mp = Struct(self.spec["message.message_properties"])
+ self.dp = Struct(self.spec["message.delivery_properties"])
+ self.fp = Struct(self.spec["message.fragment_properties"])
+
+ def testHas(self):
+ m = Message(self.mp, self.dp, self.fp, "body")
+ assert m.has("message_properties")
+ assert m.has("delivery_properties")
+ assert m.has("fragment_properties")
+
+ def testGet(self):
+ m = Message(self.mp, self.dp, self.fp, "body")
+ assert m.get("message_properties") == self.mp
+ assert m.get("delivery_properties") == self.dp
+ assert m.get("fragment_properties") == self.fp
+
+ def testSet(self):
+ m = Message(self.mp, self.dp, "body")
+ assert m.get("fragment_properties") is None
+ m.set(self.fp)
+ assert m.get("fragment_properties") == self.fp
+
+ def testSetOnEmpty(self):
+ m = Message("body")
+ assert m.get("delivery_properties") is None
+ m.set(self.dp)
+ assert m.get("delivery_properties") == self.dp
+
+ def testSetReplace(self):
+ m = Message(self.mp, self.dp, self.fp, "body")
+ dp = Struct(self.spec["message.delivery_properties"])
+ assert m.get("delivery_properties") == self.dp
+ assert m.get("delivery_properties") != dp
+ m.set(dp)
+ assert m.get("delivery_properties") != self.dp
+ assert m.get("delivery_properties") == dp
+
+ def testClear(self):
+ m = Message(self.mp, self.dp, self.fp, "body")
+ assert m.get("message_properties") == self.mp
+ assert m.get("delivery_properties") == self.dp
+ assert m.get("fragment_properties") == self.fp
+ m.clear("fragment_properties")
+ assert m.get("fragment_properties") is None
+ assert m.get("message_properties") == self.mp
+ assert m.get("delivery_properties") == self.dp