openstack/oslo.messaging
Code Issues Proposed changes

Remove unused variable WAKE_UP

Browse Source 
Change-Id: I65f57973b66f353a1e6fef3d0bf7793f821c1c5c
Closes-Bug: 1850259
This commit is contained in:
Chenjun Shen 2019-10-29 09:03:33 +01:00
parent c01b03e87c
commit 6bca848f5b
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oslo_messaging/_drivers/amqpdriver.py
View File

@ -44,6 +44,7 @@ class MessageOperationsHandler(object):
serialized and run in the same thread, since underlying drivers like kombu serialized and run in the same thread, since underlying drivers like kombu
are not thread safe. are not thread safe.
""" """
def __init__(self, name): def __init__(self, name):
self.name = "%s (%s)" % (name, hex(id(self))) self.name = "%s (%s)" % (name, hex(id(self)))
self._tasks = moves.queue.Queue() self._tasks = moves.queue.Queue()
@ -386,8 +387,6 @@ class NotificationAMQPListener(AMQPListener):
class ReplyWaiters(object): class ReplyWaiters(object):
WAKE_UP = object()
def __init__(self): def __init__(self):
self._queues = {} self._queues = {}
self._wrn_threshold = 10 self._wrn_threshold = 10