Fix a couple typos to make it easier to read.
Change-Id: If5ed92aebc873fbcab705e20922706eb46da8c39
This commit is contained in:
parent
ec68634d91
commit
410d8f0e4d
oslo_messaging
@ -668,7 +668,7 @@ class Connection(object):
|
|||||||
|
|
||||||
def _consume():
|
def _consume():
|
||||||
# NOTE(sileht):
|
# NOTE(sileht):
|
||||||
# maximun value choosen according the best practice from kombu:
|
# maximum value chosen according the best practice from kombu:
|
||||||
# http://kombu.readthedocs.org/en/latest/reference/kombu.common.html#kombu.common.eventloop
|
# http://kombu.readthedocs.org/en/latest/reference/kombu.common.html#kombu.common.eventloop
|
||||||
poll_timeout = 1 if timeout is None else min(timeout, 1)
|
poll_timeout = 1 if timeout is None else min(timeout, 1)
|
||||||
|
|
||||||
|
@ -61,7 +61,7 @@ class TimerTestCase(test_utils.BaseTestCase):
|
|||||||
remaining = t.check_return()
|
remaining = t.check_return()
|
||||||
self.assertEqual(None, remaining)
|
self.assertEqual(None, remaining)
|
||||||
|
|
||||||
def test_no_duration_but_maximun(self):
|
def test_no_duration_but_maximum(self):
|
||||||
t = common.DecayingTimer()
|
t = common.DecayingTimer()
|
||||||
t.start()
|
t.start()
|
||||||
remaining = t.check_return(maximum=2)
|
remaining = t.check_return(maximum=2)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user