QPID-5923: check requested node type when handling delete

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

1 files changed, 30 insertions, 1 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 fa7a5be0ba..4625733e30 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
@@ -197,7 +197,7 @@ class GeneralTests(Base):
     def test_node_disambiguation(self):
         agent = BrokerAgent(self.conn)
         agent.addExchange("fanout", "ambiguous")
-        queue = agent.addQueue("ambiguous")
+        agent.addQueue("ambiguous")
         try:
             r1 = self.ssn.receiver("ambiguous; {node:{type:topic}}")
             r2 = self.ssn.receiver("ambiguous; {node:{type:queue}}")
@@ -236,6 +236,35 @@ class GeneralTests(Base):
             if exchange: agent.delExchange("ambiguous")
             if queue: agent.delQueue("ambiguous", False, False)
 
+    def test_ambiguous_delete_1(self):
+        agent = BrokerAgent(self.conn)
+        agent.addExchange("fanout", "ambiguous")
+        agent.addQueue("ambiguous")
+        self.ssn.receiver("ambiguous; {delete:receiver, node:{type:topic}}").close()
+        exchange = agent.getExchange("ambiguous")
+        queue = agent.getQueue("ambiguous")
+        try:
+            assert(not exchange)
+            assert(queue)
+        finally:
+            if exchange: agent.delExchange("ambiguous")
+            if queue: agent.delQueue("ambiguous", False, False)
+
+    def test_ambiguous_delete_2(self):
+        agent = BrokerAgent(self.conn)
+        agent.addExchange("fanout", "ambiguous")
+        agent.addQueue("ambiguous")
+        self.ssn.receiver("ambiguous; {delete:receiver, node:{type:queue}}").close()
+        exchange = agent.getExchange("ambiguous")
+        queue = agent.getQueue("ambiguous")
+        try:
+            assert(exchange)
+            assert(not queue)
+        finally:
+            if exchange: agent.delExchange("ambiguous")
+            if queue: agent.delQueue("ambiguous", False, False)
+
+
 class SequenceNumberTests(Base):
     """
     Tests of ring queue sequence number