summaryrefslogtreecommitdiff
path: root/oslo_messaging/_drivers/amqpdriver.py
diff options
context:
space:
mode:
authorushen <yshxxsjt715@gmail.com>2020-04-05 20:54:03 +0800
committerushen <yshxxsjt715@gmail.com>2020-04-05 20:55:04 +0800
commit2c2779a974d59a9d91bd7cb1e3ae001952fe9083 (patch)
tree9379b2ea7d0e2868dcbd8247d1c525098acaa4dc /oslo_messaging/_drivers/amqpdriver.py
parent7f638bb493571f2a6d30d3679945119d6596cfa7 (diff)
downloadoslo-messaging-2c2779a974d59a9d91bd7cb1e3ae001952fe9083.tar.gz
Fix some typos
Change-Id: Ic0a311d290682a923ec4f8cbe36f875d560cd41a
Diffstat (limited to 'oslo_messaging/_drivers/amqpdriver.py')
-rw-r--r--oslo_messaging/_drivers/amqpdriver.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py
index a41ff24..89e3fd3 100644
--- a/oslo_messaging/_drivers/amqpdriver.py
+++ b/oslo_messaging/_drivers/amqpdriver.py
@@ -151,7 +151,7 @@ class AMQPIncomingMessage(base.RpcIncomingMessage):
except rpc_amqp.AMQPDestinationNotFound:
if timer.check_return() > 0:
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..."), {
'msg_id': self.msg_id,
'reply_q': self.reply_q})
@@ -220,7 +220,7 @@ class NotificationAMQPIncomingMessage(AMQPIncomingMessage):
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
a reply queue can be unreachable for short period
@@ -259,7 +259,7 @@ class ObsoleteReplyQueuesCache(object):
self._no_reply_log(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})