summaryrefslogtreecommitdiff
path: root/qpid
diff options
context:
space:
mode:
authorKeith Wall <kwall@apache.org>2012-11-09 12:50:57 +0000
committerKeith Wall <kwall@apache.org>2012-11-09 12:50:57 +0000
commit58df256fdc65f9dcb81a2f32075ed0a981ff5345 (patch)
tree6073535e06aedaa54094093c2c1348ca1d509763 /qpid
parent13244a93ef440b6056d40559e190bf3fc4827807 (diff)
downloadqpid-python-58df256fdc65f9dcb81a2f32075ed0a981ff5345.tar.gz
QPID-4422: removed tabs from the new test
Applied patch from Philip Harvey <phil@philharveyonline.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1407440 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid')
-rw-r--r--qpid/tests/src/py/qpid_tests/broker_0_8/basic.py18
1 files changed, 9 insertions, 9 deletions
diff --git a/qpid/tests/src/py/qpid_tests/broker_0_8/basic.py b/qpid/tests/src/py/qpid_tests/broker_0_8/basic.py
index f04d581750..606aad1293 100644
--- a/qpid/tests/src/py/qpid_tests/broker_0_8/basic.py
+++ b/qpid/tests/src/py/qpid_tests/broker_0_8/basic.py
@@ -82,26 +82,26 @@ class BasicTests(TestBase):
def test_reconnect_to_durable_subscription(self):
try:
publisherchannel = self.channel
- my_id = "my_id"
+ my_id = "my_id"
consumer_connection_properties_with_instance = {"instance": my_id}
queue_for_subscription = "queue_for_subscription_%s" % my_id
topic_name = "my_topic_name"
test_message = self.uniqueString()
- durable_subscription_client = self.connect(client_properties=consumer_connection_properties_with_instance)
+ durable_subscription_client = self.connect(client_properties=consumer_connection_properties_with_instance)
consumerchannel = durable_subscription_client.channel(1)
consumerchannel.channel_open()
self._declare_and_bind_exclusive_queue_on_topic_exchange(consumerchannel, queue_for_subscription, topic_name)
- # disconnect
- durable_subscription_client.close()
+ # disconnect
+ durable_subscription_client.close()
- # send message to topic
+ # send message to topic
publisherchannel.basic_publish(routing_key=topic_name, exchange="amq.topic", content=Content(test_message))
# reconnect and consume message
- durable_subscription_client = self.connect(client_properties=consumer_connection_properties_with_instance)
+ durable_subscription_client = self.connect(client_properties=consumer_connection_properties_with_instance)
consumerchannel = durable_subscription_client.channel(1)
consumerchannel.channel_open()
@@ -112,13 +112,13 @@ class BasicTests(TestBase):
subscription = consumerchannel.basic_consume(queue=queue_for_subscription, exclusive=True)
queue = durable_subscription_client.queue(subscription.consumer_tag)
- # consume and verify message content
+ # consume and verify message content
msg = queue.get(timeout=1)
self.assertEqual(test_message, msg.content.body)
consumerchannel.basic_ack(delivery_tag=msg.delivery_tag)
finally:
publisherchannel.queue_delete(queue=queue_for_subscription)
- durable_subscription_client.close()
+ durable_subscription_client.close()
def _declare_and_bind_exclusive_queue_on_topic_exchange(self, channel, queue, topic_name):
channel.queue_declare(queue=queue, exclusive=True, auto_delete=False, durable=True)
@@ -174,7 +174,7 @@ class BasicTests(TestBase):
myqueue = self.client.queue("my-consumer")
msg = myqueue.get(timeout=1)
self.assertEqual("One", msg.content.body)
-
+
#cancel should stop messages being delivered
channel.basic_cancel(consumer_tag="my-consumer")
channel.basic_publish(routing_key="test-queue-4", content=Content("Two"))