summaryrefslogtreecommitdiff
path: root/qpid/python/tests_0-10_preview/persistence.py
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-05-01 13:10:58 +0000
committerGordon Sim <gsim@apache.org>2008-05-01 13:10:58 +0000
commit657c6071b11a0319f78dcb96ef2978733c93c1a2 (patch)
tree8819d3095df0fbbcad38635e2026ca55a54d4659 /qpid/python/tests_0-10_preview/persistence.py
parent5fe0458b26fdf5ec233d8181201d3673a15006ae (diff)
downloadqpid-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.py67
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")
-