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