Nuke

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/tags/M2.1@646113 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 0 insertions, 76 deletions

diff --git a/RC3/python/tests/unbind.py b/RC3/python/tests/unbind.py
deleted file mode 100644
index 2ae843a604..0000000000
--- a/RC3/python/tests/unbind.py
+++ /dev/null
@@ -1,76 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-# 
-#   http://www.apache.org/licenses/LICENSE-2.0
-# 
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied.  See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-from qpid.client import Client, Closed
-from qpid.queue import Empty
-from qpid.content import Content
-from qpid.testlib import testrunner, TestBase
-
-class UnbindTests(TestBase):
-    """Tests for the unbind method introduced in 0-9"""
-    def test_unbind_direct(self):
-        self.unbind_test(exchange="amq.direct", routing_key="key")
-
-    def test_unbind_topic(self):
-        self.unbind_test(exchange="amq.topic", routing_key="key")
-
-    def test_unbind_fanout(self):
-        self.unbind_test(exchange="amq.fanout")
-
-    def test_unbind_headers(self):
-        self.unbind_test(exchange="amq.match", args={ "x-match":"all", "a":"b"}, headers={"a":"b"})
-
-    def unbind_test(self, exchange, routing_key="", args={}, headers={}):
-        #bind two queues and consume from them
-        channel = self.channel
-        
-        self.queue_declare(queue="unbind-queue-1")
-        self.queue_declare(queue="unbind-queue-2")
-
-        channel.basic_consume(queue="unbind-queue-1", consumer_tag="unbind-queue-1", no_ack=True)
-        channel.basic_consume(queue="unbind-queue-2", consumer_tag="unbind-queue-2", no_ack=True)
-
-        queue1 = self.client.queue("unbind-queue-1")
-        queue2 = self.client.queue("unbind-queue-2")
-
-        channel.queue_bind(exchange=exchange, queue="unbind-queue-1", routing_key=routing_key, arguments=args)
-        channel.queue_bind(exchange=exchange, queue="unbind-queue-2", routing_key=routing_key, arguments=args)
-
-        #send a message that will match both bindings
-        channel.basic_publish(exchange=exchange, routing_key=routing_key, content=Content("one", properties={'headers':headers}))
-        
-        #unbind first queue
-        channel.queue_unbind(exchange=exchange, queue="unbind-queue-1", routing_key=routing_key, arguments=args)
-        
-        #send another message
-        channel.basic_publish(exchange=exchange, routing_key=routing_key, content=Content("two", properties={'headers':headers}))
-
-        #check one queue has both messages and the other has only one
-        self.assertEquals("one", queue1.get(timeout=1).content.body)
-        try:
-            msg = queue1.get(timeout=1)
-            self.fail("Got extra message: %s" % msg.content.body)
-        except Empty: pass
-
-        self.assertEquals("one", queue2.get(timeout=1).content.body)
-        self.assertEquals("two", queue2.get(timeout=1).content.body)
-        try:
-            msg = queue2.get(timeout=1)
-            self.fail("Got extra message: " + msg)
-        except Empty: pass        
-