QPID-5921, QPID-5923: adjustments and exclusions for new tests using swigged client

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1613131 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 17 insertions, 6 deletions

diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py b/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py
index 4625733e30..4e94395121 100644
--- a/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py
+++ b/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py
@@ -178,34 +178,45 @@ class GeneralTests(Base):
         except Empty: pass
         self.assertEqual(received, ["a", "c"])
 
-    def _node_disambiguation_test(self, e, q):
+    def _node_disambiguation_test(self, e, q, ambiguous_send=False):
         s1 = self.ssn.sender("ambiguous; {node:{type:topic}}");
         s2 = self.ssn.sender("ambiguous; {node:{type:queue}}");
-        s3 = self.ssn.sender("ambiguous");
         s1.send(Message("a"))
         s2.send(Message("b"))
-        s3.send(Message("c"))
+        if ambiguous_send:
+            # pure python client defaults to using the queue when the
+            # node name is ambiguous and no type is specified; the
+            # swigged version treats this as an error
+            s3 = self.ssn.sender("ambiguous");
+            s3.send(Message("c"))
         self.assertEqual(e.fetch().content, "a")
         self.assertEqual(q.fetch().content, "b")
-        self.assertEqual(q.fetch().content, "c")
+        if ambiguous_send:
+            self.assertEqual(q.fetch().content, "c")
         for r in [e, q]:
             try:
                 m = r.fetch(timeout=0)
                 self.fail("Found unexpected message %s")
             except Empty: pass
 
-    def test_node_disambiguation(self):
+    def _node_disambiguation_precreated(self, ambiguous_send):
         agent = BrokerAgent(self.conn)
         agent.addExchange("fanout", "ambiguous")
         agent.addQueue("ambiguous")
         try:
             r1 = self.ssn.receiver("ambiguous; {node:{type:topic}}")
             r2 = self.ssn.receiver("ambiguous; {node:{type:queue}}")
-            self._node_disambiguation_test(r1, r2)
+            self._node_disambiguation_test(r1, r2, ambiguous_send=ambiguous_send)
         finally:
             agent.delExchange("ambiguous")
             agent.delQueue("ambiguous", False, False)
 
+    def test_node_disambiguation_1(self):
+        self._node_disambiguation_precreated(False)
+
+    def test_node_disambiguation_2(self):
+        self._node_disambiguation_precreated(True)
+
     def test_ambiguous_create_1(self):
         #create queue first, then exchange
         r1 = self.ssn.receiver("ambiguous; {create:receiver, node:{type:queue}}")