diff options
| -rw-r--r-- | oslo_messaging/_drivers/amqpdriver.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py index f5c5997..ccab0ce 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 |