diff options
| author | Gordon Sim <gsim@apache.org> | 2008-05-01 13:10:58 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-05-01 13:10:58 +0000 |
| commit | 657c6071b11a0319f78dcb96ef2978733c93c1a2 (patch) | |
| tree | 8819d3095df0fbbcad38635e2026ca55a54d4659 /qpid/python/tests_0-10_preview/persistence.py | |
| parent | 5fe0458b26fdf5ec233d8181201d3673a15006ae (diff) | |
| download | qpid-python-657c6071b11a0319f78dcb96ef2978733c93c1a2.tar.gz | |
Remove preview tests (no longer required)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@652506 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/tests_0-10_preview/persistence.py')
| -rw-r--r-- | qpid/python/tests_0-10_preview/persistence.py | 67 |
1 files changed, 0 insertions, 67 deletions
diff --git a/qpid/python/tests_0-10_preview/persistence.py b/qpid/python/tests_0-10_preview/persistence.py deleted file mode 100644 index ad578474eb..0000000000 --- a/qpid/python/tests_0-10_preview/persistence.py +++ /dev/null @@ -1,67 +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 PersistenceTests(TestBase): - def test_delete_queue_after_publish(self): - channel = self.channel - channel.synchronous = False - - #create queue - channel.queue_declare(queue = "q", auto_delete=True, durable=True) - - #send message - for i in range(1, 10): - channel.message_transfer(content=Content(properties={'routing_key' : "q", 'delivery_mode':2}, body = "my-message")) - - channel.synchronous = True - #explicitly delete queue - channel.queue_delete(queue = "q") - - def test_ack_message_from_deleted_queue(self): - channel = self.channel - channel.synchronous = False - - #create queue - channel.queue_declare(queue = "q", auto_delete=True, durable=True) - - #send message - channel.message_transfer(content=Content(properties={'routing_key' : "q", 'delivery_mode':2}, body = "my-message")) - - #create consumer - channel.message_subscribe(queue = "q", destination = "a", confirm_mode = 1, acquire_mode=0) - channel.message_flow(unit = 1, value = 0xFFFFFFFF, destination = "a") - channel.message_flow(unit = 0, value = 10, destination = "a") - queue = self.client.queue("a") - - #consume the message, cancel subscription (triggering auto-delete), then ack it - msg = queue.get(timeout = 5) - channel.message_cancel(destination = "a") - msg.complete() - - def test_queue_deletion(self): - channel = self.channel - channel.queue_declare(queue = "durable-subscriber-queue", exclusive=True, durable=True) - channel.queue_bind(exchange="amq.topic", queue="durable-subscriber-queue", routing_key="xyz") - channel.message_transfer(destination= "amq.topic", content=Content(properties={'routing_key' : "xyz", 'delivery_mode':2}, body = "my-message")) - channel.queue_delete(queue = "durable-subscriber-queue") - |
