Add rabbit_durable_queues config option.

Fixes bug 1054183 Avoid AMQPChannelException: (406, "PRECONDITION_FAILED...") failures due to a mismatch between the durability of rabbitmq exchange/queue declared by glance and ceilometer. Change-Id: I4e25986a1f503782e701aa1168c4eb231ff25d06
openstack · Sep 21, 2012 · 5268d6b · 5268d6b
1 parent 7b84172
commit 5268d6b
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/doc/source/configuring.rst b/doc/source/configuring.rst
@@ -795,6 +795,12 @@ Optional. Default: ``30``
 Maximum seconds to wait before reconnecting on failures when using
 ``rabbit`` strategy.
 
+* ``rabbit_durable_queues``
+
+Optional. Default: ``False``
+
+Controls durability of exchange and queue when using ``rabbit`` strategy.
+
 * ``qpid_notification_exchange``
 
 Optional. Default: ``glance``

diff --git a/etc/glance-api.conf b/etc/glance-api.conf
@@ -149,6 +149,7 @@ rabbit_password = guest
 rabbit_virtual_host = /
 rabbit_notification_exchange = glance
 rabbit_notification_topic = glance_notifications
+rabbit_durable_queues = False
 
 # Configuration options if sending notifications via Qpid (these are
 # the defaults)

diff --git a/glance/notifier/notify_kombu.py b/glance/notifier/notify_kombu.py
@@ -38,8 +38,9 @@
                default='glance_notifications'),
     cfg.StrOpt('rabbit_max_retries', default=0),
     cfg.StrOpt('rabbit_retry_backoff', default=2),
-    cfg.StrOpt('rabbit_retry_max_backoff', default=30)
-    ]
+    cfg.StrOpt('rabbit_retry_max_backoff', default=30),
+    cfg.StrOpt('rabbit_durable_queues', default=False),
+]
 
 CONF = cfg.CONF
 CONF.register_opts(rabbit_opts)
@@ -103,6 +104,7 @@ def _connect(self):
         self.exchange = kombu.entity.Exchange(
                 channel=self.channel,
                 type="topic",
+                durable=CONF.rabbit_durable_queues,
                 name=CONF.rabbit_notification_exchange)
 
         # NOTE(jerdfelt): Normally the consumer would create the queues,
@@ -113,7 +115,7 @@ def _connect(self):
             queue = kombu.entity.Queue(
                     channel=self.channel,
                     exchange=self.exchange,
-                    durable=True,
+                    durable=CONF.rabbit_durable_queues,
                     name=routing_key,
                     routing_key=routing_key)
             queue.declare()