diff options
| author | Jenkins <jenkins@review.openstack.org> | 2015-03-07 23:37:42 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2015-03-07 23:37:42 +0000 |
| commit | ff4eb4db1b58227d0c0736a0c00d99d3fc73d79b (patch) | |
| tree | bf92516a2d8967043d01bc4fa70f7d9bb2276607 | |
| parent | 71f966b868dbf91b8fa6da6bc355684bde699234 (diff) | |
| parent | 0359147713c4a1e4b77fce60ad45c367f70f0059 (diff) | |
| download | oslo-messaging-ff4eb4db1b58227d0c0736a0c00d99d3fc73d79b.tar.gz | |
Merge "NotifyPublisher need handle amqp_auto_delete"1.8.0
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index c66daf7..b06d290 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -439,6 +439,7 @@ class NotifyPublisher(TopicPublisher): def __init__(self, conf, channel, exchange_name, topic, **kwargs): self.durable = kwargs.pop('durable', conf.amqp_durable_queues) + self.auto_delete = kwargs.pop('auto_delete', conf.amqp_auto_delete) self.queue_arguments = _get_queue_arguments(conf) super(NotifyPublisher, self).__init__(conf, channel, exchange_name, topic, **kwargs) @@ -452,6 +453,7 @@ class NotifyPublisher(TopicPublisher): queue = kombu.entity.Queue(channel=channel, exchange=self.exchange, durable=self.durable, + auto_delete=self.auto_delete, name=self.routing_key, routing_key=self.routing_key, queue_arguments=self.queue_arguments) |