openstack/oslo.messaging
Code Issues Proposed changes

Fix some typos

Browse Source 
Change-Id: Ic0a311d290682a923ec4f8cbe36f875d560cd41a
This commit is contained in:
ushen 2020-04-05 20:54:03 +08:00
parent 7f638bb493
commit 2c2779a974
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
oslo_messaging/_drivers/amqpdriver.py
View File

@ -151,7 +151,7 @@ class AMQPIncomingMessage(base.RpcIncomingMessage):
except rpc_amqp.AMQPDestinationNotFound: except rpc_amqp.AMQPDestinationNotFound:
if timer.check_return() > 0: if timer.check_return() > 0:
LOG.debug(("The reply %(msg_id)s cannot be sent " LOG.debug(("The reply %(msg_id)s cannot be sent "
"%(reply_q)s reply queue don't exist, " "%(reply_q)s reply queue doesn't exist, "
"retrying..."), { "retrying..."), {
'msg_id': self.msg_id, 'msg_id': self.msg_id,
'reply_q': self.reply_q}) 'reply_q': self.reply_q})
@ -220,7 +220,7 @@ class NotificationAMQPIncomingMessage(AMQPIncomingMessage):
class ObsoleteReplyQueuesCache(object): class ObsoleteReplyQueuesCache(object):
"""Cache of reply queue id that doesn't exists anymore. """Cache of reply queue id that doesn't exist anymore.
NOTE(sileht): In case of a broker restart/failover NOTE(sileht): In case of a broker restart/failover
a reply queue can be unreachable for short period a reply queue can be unreachable for short period
@ -259,7 +259,7 @@ class ObsoleteReplyQueuesCache(object):
self._no_reply_log(reply_q, msg_id) self._no_reply_log(reply_q, msg_id)
def _no_reply_log(self, reply_q, msg_id): def _no_reply_log(self, reply_q, msg_id):
LOG.warning("%(reply_queue)s doesn't exists, drop reply to " LOG.warning("%(reply_queue)s doesn't exist, drop reply to "
"%(msg_id)s", {'reply_queue': reply_q, "msg_id": msg_id}) "%(msg_id)s", {'reply_queue': reply_q, "msg_id": msg_id})

4
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -59,7 +59,7 @@ else:
# we will facing an issue by trying to override the threading module. # we will facing an issue by trying to override the threading module.
stdlib_threading = threading stdlib_threading = threading
# NOTE(sileht): don't exists in py2 socket module # NOTE(sileht): don't exist in py2 socket module
TCP_USER_TIMEOUT = 18 TCP_USER_TIMEOUT = 18
rabbit_opts = [ rabbit_opts = [
@ -1286,7 +1286,7 @@ class Connection(object):
# the 404 kombu ChannelError and retry until the exchange # the 404 kombu ChannelError and retry until the exchange
# appears # appears
raise rpc_amqp.AMQPDestinationNotFound( raise rpc_amqp.AMQPDestinationNotFound(
"exchange %s doesn't exists" % exchange.name) "exchange %s doesn't exist" % exchange.name)
raise raise
def direct_send(self, msg_id, msg): def direct_send(self, msg_id, msg):