Merge pull request #4406 from blomquisg/openstack-close-rabbit-queues

[Openstack] Delete rabbit queues when the connection closes
ManageIQ · Sep 17, 2015 · 711ec1a · 711ec1a
2 parents 3ea9703 + 970d1ad
commit 711ec1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/gems/pending/openstack/amqp/openstack_rabbit_event_monitor.rb b/gems/pending/openstack/amqp/openstack_rabbit_event_monitor.rb
@@ -98,7 +98,7 @@ def initialize_queues(channel)
       @options[:topics].each do |exchange, topic|
         amqp_exchange = channel.topic(exchange)
         queue_name = "miq-#{@client_ip}-#{exchange}"
-        @queues[exchange] = channel.queue(queue_name).bind(amqp_exchange, :routing_key => topic)
+        @queues[exchange] = channel.queue(queue_name, :auto_delete => true, :exclusive => true).bind(amqp_exchange, :routing_key => topic)
       end
     end
   end