From 39eb9755d71d77df1e67e5a51e5bf3d1e4e8da04 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Wed, 3 Jun 2009 17:24:25 +0000 Subject: added tests for sender git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@781485 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/tests/messaging.py | 35 +++++++++++++++++++++++++++++++++++ 1 file changed, 35 insertions(+) (limited to 'python') diff --git a/python/qpid/tests/messaging.py b/python/qpid/tests/messaging.py index e32b91a26b..ed02d7a27a 100644 --- a/python/qpid/tests/messaging.py +++ b/python/qpid/tests/messaging.py @@ -385,6 +385,41 @@ class ReceiverTests(Base): # XXX: need testClose +class SenderTests(Base): + + def setup_connection(self): + return Connection.open(self.broker.host, self.broker.port) + + def setup_session(self): + return self.conn.session() + + def setup_sender(self): + return self.ssn.sender("test-sender-queue") + + def setup_receiver(self): + return self.ssn.receiver("test-sender-queue") + + def checkContent(self, content): + self.snd.send(content) + msg = self.rcv.fetch(0) + assert msg.content == content + + out = Message(content) + self.snd.send(out) + echo = self.rcv.fetch(0) + assert out.content == echo.content + assert echo.content == msg.content + self.ssn.acknowledge() + + def testSendString(self): + self.checkContent("testSendString[%s]" % uuid4()) + + def testSendList(self): + self.checkContent(["testSendList", 1, 3.14, uuid4()]) + + def testSendMap(self): + self.checkContent({"testSendMap": uuid4(), "pie": "blueberry", "pi": 3.14}) + class MessageTests(Base): def testCreateString(self): -- cgit v1.2.1