Merge "Fix some typos"
This commit is contained in:
commit
cf23a0d37a
@ -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})
|
||||
|
||||
|
||||
|
@ -59,7 +59,7 @@ else:
|
||||
# we will facing an issue by trying to override the threading module.
|
||||
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
|
||||
|
||||
rabbit_opts = [
|
||||
@ -1286,7 +1286,7 @@ class Connection(object):
|
||||
# the 404 kombu ChannelError and retry until the exchange
|
||||
# appears
|
||||
raise rpc_amqp.AMQPDestinationNotFound(
|
||||
"exchange %s doesn't exists" % exchange.name)
|
||||
"exchange %s doesn't exist" % exchange.name)
|
||||
raise
|
||||
|
||||
def direct_send(self, msg_id, msg):
|
||||
|
Loading…
Reference in New Issue
Block a user