openstack/oslo.messaging
Code Issues Proposed changes

Typos of 'recieve' instead of 'receive'

Browse Source 
* i before e unless before c
* Also updated the docstring on consume function

Change-Id: Icfe35fc577d01434839d6774d02b933fc4cd1a08
This commit is contained in:
Eric Brown 2016-02-22 22:15:18 -08:00
parent 92c4f76c79
commit 5fd3b1509b
2 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
oslo_messaging/_drivers/impl_kafka.py
View File

@ -144,11 +144,9 @@ class Connection(object):
self.producer.send_messages(topic, message)
def consume(self, timeout=None):
"""recieve messages as many as max_fetch_messages.
"""Receive up to 'max_fetch_messages' messages.
In this functions, there are no while loop to subscribe.
This would be helpful when we wants to control the velocity of
subscription.
:param timeout: poll timeout in seconds
"""
duration = (self.consumer_timeout if timeout is None else timeout)
timer = driver_common.DecayingTimer(duration=duration)

6
oslo_messaging/tests/drivers/test_impl_kafka.py
View File

@ -238,7 +238,7 @@ class TestWithRealKafkaBroker(test_utils.BaseTestCase):
@unittest.skipUnless(
_is_kafka_service_running(), "Kafka service is not available")
def test_send_and_recieve_message(self):
def test_send_and_receive_message(self):
target = oslo_messaging.Target(
topic="fake_topic", exchange='fake_exchange')
targets_and_priorities = [(target, 'fake_info')]
@ -256,7 +256,7 @@ class TestWithRealKafkaBroker(test_utils.BaseTestCase):
@unittest.skipUnless(
_is_kafka_service_running(), "Kafka service is not available")
def test_send_and_recieve_message_without_exchange(self):
def test_send_and_receive_message_without_exchange(self):
target = oslo_messaging.Target(topic="fake_no_exchange_topic")
targets_and_priorities = [(target, 'fake_info')]
@ -273,7 +273,7 @@ class TestWithRealKafkaBroker(test_utils.BaseTestCase):
@unittest.skipUnless(
_is_kafka_service_running(), "Kafka service is not available")
def test_recieve_message_from_empty_topic_with_timeout(self):
def test_receive_message_from_empty_topic_with_timeout(self):
target = oslo_messaging.Target(
topic="fake_empty_topic", exchange='fake_empty_exchange')
targets_and_priorities = [(target, 'fake_info')]