Added self.auto_delete = True to the Publisher subclasses that did not have that set.

This commit is contained in:
Ed Leafe
2011-06-30 20:50:31 +00:00
parent c7ee39c3d0
commit ae21a37373

View File

@@ -348,6 +348,7 @@ class TopicPublisher(Publisher):
self.routing_key = topic
self.exchange = FLAGS.control_exchange
self.durable = False
self.auto_delete = True
super(TopicPublisher, self).__init__(connection=connection)
@@ -360,6 +361,7 @@ class FanoutPublisher(Publisher):
self.exchange = '%s_fanout' % topic
self.queue = '%s_fanout' % topic
self.durable = False
self.auto_delete = True
LOG.info(_('Creating "%(exchange)s" fanout exchange'),
dict(exchange=self.exchange))
super(FanoutPublisher, self).__init__(connection=connection)