diff options
| author | Joshua McKenty <joshua.mckenty@nasa.gov> | 2010-07-16 14:07:57 -0700 |
|---|---|---|
| committer | Joshua McKenty <joshua.mckenty@nasa.gov> | 2010-07-16 14:07:57 -0700 |
| commit | f6aeb0a121e76aefa8b6af6ae602df76c2419b2e (patch) | |
| tree | 40d1710c7cff118967b95bc28aa508fcdb6a83b3 /nova/rpc.py | |
| parent | 6892ff871b1a154bbe669bf5cb10eab638fb181b (diff) | |
| download | nova-f6aeb0a121e76aefa8b6af6ae602df76c2419b2e.tar.gz nova-f6aeb0a121e76aefa8b6af6ae602df76c2419b2e.tar.xz nova-f6aeb0a121e76aefa8b6af6ae602df76c2419b2e.zip | |
Makin the queues non-durable by default
Diffstat (limited to 'nova/rpc.py')
| -rw-r--r-- | nova/rpc.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index 99e820ff3..c6ebb1160 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -112,6 +112,7 @@ class TopicConsumer(Consumer): self.queue = topic self.routing_key = topic self.exchange = FLAGS.control_exchange + self.durable = False super(TopicConsumer, self).__init__(connection=connection) @@ -238,7 +239,8 @@ def send_message(topic, message, wait=True): exchange=msg_id, auto_delete=True, exchange_type="direct", - routing_key=msg_id) + routing_key=msg_id, + durable=False) consumer.register_callback(generic_response) publisher = messaging.Publisher(connection=Connection.instance(), |