summaryrefslogtreecommitdiffstats
path: root/tests/unit/rpc
diff options
context:
space:
mode:
authorSergey Lukjanov <slukjanov@mirantis.com>2013-06-02 20:41:20 +0400
committerSergey Lukjanov <slukjanov@mirantis.com>2013-06-03 07:53:21 +0400
commite3545f828dabe165dc08b2f1670e5f1f19919d0d (patch)
treeead970c643632ed624c6bda25e902f47cf13b49e /tests/unit/rpc
parent15d8d698b7c67c43dc7a2b0c2c6952734bd2ba66 (diff)
Enable hacking H402 test
H402 one line docstring needs punctuation Change-Id: Ie848453cace318d8310cdf0234c512f4c1121119
Diffstat (limited to 'tests/unit/rpc')
-rw-r--r--tests/unit/rpc/amqp.py2
-rw-r--r--tests/unit/rpc/test_kombu.py16
-rw-r--r--tests/unit/rpc/test_service.py4
3 files changed, 11 insertions, 11 deletions
diff --git a/tests/unit/rpc/amqp.py b/tests/unit/rpc/amqp.py
index 69d647a..432dd35 100644
--- a/tests/unit/rpc/amqp.py
+++ b/tests/unit/rpc/amqp.py
@@ -223,7 +223,7 @@ class BaseRpcAMQPTestCase(common.BaseRpcTestCase):
self.config(amqp_rpc_single_reply_queue=False)
def test_duplicate_message_check(self):
- """Test sending *not-dict* to a topic exchange/queue"""
+ """Test sending *not-dict* to a topic exchange/queue."""
conn = self.rpc.create_connection(FLAGS)
message = {'args': 'topic test message', '_unique_id': 'aaaabbbbcccc'}
diff --git a/tests/unit/rpc/test_kombu.py b/tests/unit/rpc/test_kombu.py
index a524c73..159fefb 100644
--- a/tests/unit/rpc/test_kombu.py
+++ b/tests/unit/rpc/test_kombu.py
@@ -95,7 +95,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
self.assertEqual(conn1, conn2)
def test_topic_send_receive(self):
- """Test sending to a topic exchange/queue"""
+ """Test sending to a topic exchange/queue."""
conn = self.rpc.create_connection(FLAGS)
message = 'topic test message'
@@ -132,7 +132,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
conn.close()
def test_topic_send_receive_exchange_name(self):
- """Test sending to a topic exchange/queue with an exchange name"""
+ """Test sending to a topic exchange/queue with an exchange name."""
conn = self.rpc.create_connection(FLAGS)
message = 'topic test message'
@@ -151,7 +151,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
self.assertEqual(self.received_message, message)
def test_topic_multiple_queues(self):
- """Test sending to a topic exchange with multiple queues"""
+ """Test sending to a topic exchange with multiple queues."""
conn = self.rpc.create_connection(FLAGS)
message = 'topic test message'
@@ -233,7 +233,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
self.assertEqual(self.received_message_2, message)
def test_direct_send_receive(self):
- """Test sending to a direct exchange/queue"""
+ """Test sending to a direct exchange/queue."""
conn = self.rpc.create_connection(FLAGS)
message = 'direct test message'
@@ -250,7 +250,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
self.assertEqual(self.received_message, message)
def test_cast_interface_uses_default_options(self):
- """Test kombu rpc.cast"""
+ """Test kombu rpc.cast."""
ctxt = rpc_common.CommonRpcContext(user='fake_user',
project='fake_project')
@@ -276,7 +276,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
impl_kombu.cast(FLAGS, ctxt, 'fake_topic', {'msg': 'fake'})
def test_cast_to_server_uses_server_params(self):
- """Test kombu rpc.cast"""
+ """Test kombu rpc.cast."""
ctxt = rpc_common.CommonRpcContext(user='fake_user',
project='fake_project')
@@ -309,7 +309,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
'fake_topic', {'msg': 'fake'})
def test_fanout_send_receive(self):
- """Test sending to a fanout exchange and consuming from 2 queues"""
+ """Test sending to a fanout exchange and consuming from 2 queues."""
self.skipTest("kombu memory transport seems buggy with "
"fanout queues as this test passes when "
@@ -366,7 +366,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase):
self.assertTrue(isinstance(result, self.rpc.DirectConsumer))
def test_declare_consumer_ioerrors_will_reconnect(self):
- """Test that an IOError exception causes a reconnection"""
+ """Test that an IOError exception causes a reconnection."""
info = _raise_exc_stub(self.stubs, 2, self.rpc.DirectConsumer,
'__init__', 'Socket closed', exc_class=IOError)
diff --git a/tests/unit/rpc/test_service.py b/tests/unit/rpc/test_service.py
index 9293d3e..e9f8313 100644
--- a/tests/unit/rpc/test_service.py
+++ b/tests/unit/rpc/test_service.py
@@ -21,7 +21,7 @@ from tests import utils
class FakeService(service.Service):
- """Fake manager for tests"""
+ """Fake manager for tests."""
def __init__(self, host, topic):
super(FakeService, self).__init__(host, topic, None)
self.method_result = 'manager'
@@ -43,7 +43,7 @@ class FakeHookService(FakeService):
class RpcServiceManagerTestCase(utils.BaseTestCase):
- """Test cases for Services"""
+ """Test cases for Services."""
def setUp(self):
super(RpcServiceManagerTestCase, self).setUp()
self.config(fake_rabbit=True)