Enables the exclusive flag for DirectConsumer queues.

2010-11-03 23:04:01 +00:00
parent c6e147efce 6403c61db7
commit 8963ec1aa6
1 changed files with 1 additions and 0 deletions
--- a/nova/rpc.py
+++ b/nova/rpc.py
@@ -206,6 +206,7 @@ class DirectConsumer(Consumer):
        self.routing_key = msg_id
        self.exchange = msg_id
        self.auto_delete = True
+        self.exclusive = True
        super(DirectConsumer, self).__init__(connection=connection)