diff options
| author | Sandy Walsh <sandy.walsh@rackspace.com> | 2011-06-29 19:36:53 -0700 |
|---|---|---|
| committer | Sandy Walsh <sandy.walsh@rackspace.com> | 2011-06-29 19:36:53 -0700 |
| commit | 76a0aca9351f0888a75ec743369e488b7cc6dba4 (patch) | |
| tree | 88e117492e2efda93b93ae936dfc66cb5e1188a6 /nova/rpc.py | |
| parent | d17171b4277337388b372459571d9f3904798bca (diff) | |
| parent | d77526e357fe3764107d4d5fda768b69b52fb015 (diff) | |
| download | nova-76a0aca9351f0888a75ec743369e488b7cc6dba4.tar.gz | |
trunk merge
Diffstat (limited to 'nova/rpc.py')
| -rw-r--r-- | nova/rpc.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index 4649ac1573..5e0796a215 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -275,6 +275,11 @@ class FanoutAdapterConsumer(AdapterConsumer): unique = uuid.uuid4().hex self.queue = '%s_fanout_%s' % (topic, unique) self.durable = False + # Fanout creates unique queue names, so we should auto-remove + # them when done, so they're not left around on restart. + # Also, we're the only one that should be consuming. exclusive + # implies auto_delete, so we'll just set that.. + self.exclusive = True LOG.info(_('Created "%(exchange)s" fanout exchange ' 'with "%(key)s" routing key'), dict(exchange=self.exchange, key=self.routing_key)) |