From 0539fb89df2c2822f14bcc473911c6ad3aa0e9a5 Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Thu, 12 Aug 2010 18:37:19 +0000
Subject: fixed reply-to conversion

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@984906 13f79535-47bb-0310-9956-ffa450edef68
---
 python/qpid/tests/messaging/message.py | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)

(limited to 'python/qpid/tests/messaging')

diff --git a/python/qpid/tests/messaging/message.py b/python/qpid/tests/messaging/message.py
index 526a5cfab6..eaa953e7d7 100644
--- a/python/qpid/tests/messaging/message.py
+++ b/python/qpid/tests/messaging/message.py
@@ -117,3 +117,27 @@ class MessageEchoTests(Base):
 
   def testTextPlainEmpty(self):
     self.check(Message(content_type="text/plain"))
+
+  def check_rt(self, addr, expected=None):
+    if expected is None:
+      expected = addr
+    msg = Message(reply_to=addr)
+    self.snd.send(msg)
+    echo = self.rcv.fetch(0)
+    assert echo.reply_to == expected, echo.reply_to
+    self.ssn.acknowledge(echo)
+
+  def testReplyTo(self):
+    self.check_rt("name")
+
+  def testReplyToQueue(self):
+    self.check_rt("name; {node: {type: queue}}", "name")
+
+  def testReplyToQueueSubject(self):
+    self.check_rt("name/subject; {node: {type: queue}}", "name")
+
+  def testReplyToTopic(self):
+    self.check_rt("name; {node: {type: topic}}")
+
+  def testReplyToTopicSubject(self):
+    self.check_rt("name/subject; {node: {type: topic}}")
-- 
cgit v1.2.1